revert to asyncio.get_event_loop().run_until_complete(outputs)

cosmicBboy · cosmicBboy · commit 26cec32b59c1 · 2024-09-09T12:29:32.000-04:00
Signed-off-by: Niels Bantilan &lt;niels.bantilan@gmail.com&gt;
diff --git a/flytekit/bin/entrypoint.py b/flytekit/bin/entrypoint.py
@@ -107,8 +107,7 @@ def _dispatch_execute(
         if inspect.iscoroutine(outputs):
             # Handle eager-mode (async) tasks
             logger.info("Output is a coroutine")
-            with asyncio.Runner() as runner:
-                outputs = runner.run(outputs)
+            outputs = asyncio.get_event_loop().run_until_complete(outputs)
 
         # Step3a
         if isinstance(outputs, VoidPromise):
