removed asyncio 3.6 compat

MatterMiners · Jul 26, 2023 · 197dc1b · 197dc1b
1 parent e78096e
commit 197dc1b
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 55 deletions.
diff --git a/src/cobald/daemon/runners/_compat.py b/src/cobald/daemon/runners/_compat.py
diff --git a/src/cobald/daemon/runners/asyncio_runner.py b/src/cobald/daemon/runners/asyncio_runner.py
@@ -2,7 +2,6 @@
 import asyncio
 
 from .base_runner import BaseRunner, OrphanedReturn
-from ._compat import asyncio_current_task
 
 
 class AsyncioRunner(BaseRunner):
@@ -46,7 +45,7 @@ async def _monitor_payload(self, payload: Callable[[], Awaitable]):
             if result is None:
                 return
             failure = OrphanedReturn(payload, result)
-        self._tasks.discard(asyncio_current_task())
+        self._tasks.discard(asyncio.current_task())
         if not self._payload_failure.done():
             self._payload_failure.set_exception(failure)
 

diff --git a/src/cobald/daemon/runners/meta_runner.py b/src/cobald/daemon/runners/meta_runner.py
@@ -9,7 +9,6 @@
 from .trio_runner import TrioRunner
 from .asyncio_runner import AsyncioRunner
 from .thread_runner import ThreadRunner
-from ._compat import asyncio_run
 
 from ..debug import NameRepr
 
@@ -67,7 +66,7 @@ def run(self):
         """Run all runners, blocking until completion or error"""
         self._logger.info("starting all runners")
         try:
-            asyncio_run(self._manage_runners())
+            asyncio.run(self._manage_runners())
         except KeyboardInterrupt:
             self._logger.info("runner interrupted")
         except Exception as err: