maybe

Author: sanderegg

services/director-v2/src/simcore_service_director_v2/modules/comp_scheduler/_scheduler_base.py

@@ -12,6 +12,8 @@
 """
 
 import asyncio
+import concurrent
+import concurrent.futures
 import datetime
 import logging
 from abc import ABC, abstractmethod
@@ -78,6 +80,7 @@
 
 
 def _auto_schedule_callback(
+    loop: asyncio.AbstractEventLoop,
     db_engine: Engine,
     rabbit_mq_client: RabbitMQClient,
     *,
@@ -95,11 +98,13 @@ async def _async_cb():
                 iteration=iteration,
             )
 
-        future = asyncio.run_coroutine_threadsafe(
-            _async_cb(), asyncio.get_running_loop()
-        )
-        with log_catch(_logger, reraise=False):
-            future.result(timeout=10)
+        future = asyncio.run_coroutine_threadsafe(_async_cb(), loop)
+
+        def handle_future_result(fut: concurrent.futures.Future) -> None:
+            with log_catch(_logger, reraise=False):
+                fut.result(timeout=10)
+
+        future.add_done_callback(handle_future_result)
 
     return _cb