ITQC/pydase
24
0
Fork 0
mirror of https://github.com/tiqi-group/pydase.git synced 2025-04-23 09:30:02 +02:00
Code Issues Packages Projects Releases Wiki Activity

fixes task manager loop

Browse Source
This commit is contained in:
Mose Müller 2023-12-21 13:11:17 +01:00
parent 316ce5c7e7
commit c733026522
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/pydase/data_service/task_manager.py
View File

@ -77,7 +77,6 @@ class TaskManager:
def __init__(self, service: DataService) -> None: def __init__(self, service: DataService) -> None:
self.service = service self.service = service
self._loop = asyncio.get_event_loop()
self.tasks: dict[str, TaskDict] = {} self.tasks: dict[str, TaskDict] = {}
"""A dictionary to keep track of running tasks. The keys are the names of the """A dictionary to keep track of running tasks. The keys are the names of the
@ -87,6 +86,10 @@ class TaskManager:
self._set_start_and_stop_for_async_methods() self._set_start_and_stop_for_async_methods()
@property
def _loop(self) -> asyncio.AbstractEventLoop:
return asyncio.get_running_loop()
def _set_start_and_stop_for_async_methods(self) -> None: def _set_start_and_stop_for_async_methods(self) -> None:
# inspect the methods of the class # inspect the methods of the class
for name, method in inspect.getmembers( for name, method in inspect.getmembers(