mirror of
https://github.com/tiqi-group/pydase.git
synced 2025-04-21 00:40:01 +02:00
fix: removes aiohttp warnings (popping up when running pytest)
This commit is contained in:
parent
c1ace54c78
commit
2bcc6b9660
@ -1,5 +1,6 @@
|
|||||||
import inspect
|
import inspect
|
||||||
import logging
|
import logging
|
||||||
|
from functools import partial
|
||||||
from typing import TYPE_CHECKING
|
from typing import TYPE_CHECKING
|
||||||
|
|
||||||
import aiohttp.web
|
import aiohttp.web
|
||||||
@ -25,7 +26,7 @@ STATUS_FAILED = 400
|
|||||||
|
|
||||||
|
|
||||||
async def _get_value(
|
async def _get_value(
|
||||||
state_manager: StateManager, request: aiohttp.web.Request
|
request: aiohttp.web.Request, state_manager: StateManager
|
||||||
) -> aiohttp.web.Response:
|
) -> aiohttp.web.Response:
|
||||||
logger.info("Handle api request: %s", request)
|
logger.info("Handle api request: %s", request)
|
||||||
|
|
||||||
@ -42,7 +43,7 @@ async def _get_value(
|
|||||||
|
|
||||||
|
|
||||||
async def _update_value(
|
async def _update_value(
|
||||||
state_manager: StateManager, request: aiohttp.web.Request
|
request: aiohttp.web.Request, state_manager: StateManager
|
||||||
) -> aiohttp.web.Response:
|
) -> aiohttp.web.Response:
|
||||||
data: UpdateDict = await request.json()
|
data: UpdateDict = await request.json()
|
||||||
|
|
||||||
@ -56,7 +57,7 @@ async def _update_value(
|
|||||||
|
|
||||||
|
|
||||||
async def _trigger_method(
|
async def _trigger_method(
|
||||||
state_manager: StateManager, request: aiohttp.web.Request
|
request: aiohttp.web.Request, state_manager: StateManager
|
||||||
) -> aiohttp.web.Response:
|
) -> aiohttp.web.Response:
|
||||||
data: TriggerMethodDict = await request.json()
|
data: TriggerMethodDict = await request.json()
|
||||||
|
|
||||||
@ -83,16 +84,13 @@ def create_api_application(state_manager: StateManager) -> aiohttp.web.Applicati
|
|||||||
)
|
)
|
||||||
|
|
||||||
api_application.router.add_get(
|
api_application.router.add_get(
|
||||||
"/get_value",
|
"/get_value", partial(_get_value, state_manager=state_manager)
|
||||||
lambda request: _get_value(state_manager=state_manager, request=request),
|
|
||||||
)
|
)
|
||||||
api_application.router.add_put(
|
api_application.router.add_put(
|
||||||
"/update_value",
|
"/update_value", partial(_update_value, state_manager=state_manager)
|
||||||
lambda request: _update_value(state_manager=state_manager, request=request),
|
|
||||||
)
|
)
|
||||||
api_application.router.add_put(
|
api_application.router.add_put(
|
||||||
"/trigger_method",
|
"/trigger_method", partial(_trigger_method, state_manager=state_manager)
|
||||||
lambda request: _trigger_method(state_manager=state_manager, request=request),
|
|
||||||
)
|
)
|
||||||
|
|
||||||
return api_application
|
return api_application
|
||||||
|
Loading…
x
Reference in New Issue
Block a user