Fix

2026-09-06 17:57:49 +02:00 · 2025-01-21 09:42:25 -08:00
parent 12be3fac33
commit c7c62f5587
1 changed files with 1 additions and 2 deletions
@@ -407,8 +407,7 @@ class PregelRunner:
            # return a chained future to ensure commit() callback is called
            # before the returned future is resolved, to ensure stream order etc
            try:
-                asyncio.current_task()
-                in_async = True
+                in_async = asyncio.current_task() is not None
            except RuntimeError:
                in_async = False
            # if in async context return an async future