Less fun

2026-09-28 04:25:08 +02:00 · 2024-09-17 17:51:18 -07:00
parent 3a2a4e44b2
commit 2a769fb39e
1 changed files with 2 additions and 1 deletions
@@ -1245,7 +1245,8 @@ class Pregel(Runnable[Union[dict[str, Any], Any], Union[dict[str, Any], Any]]):
                    def get_waiter() -> asyncio.Task[None]:
                        nonlocal waiter
                        if waiter is None or waiter.done():
-                            return (waiter := loop.submit(stream.wait))
+                            waiter = loop.submit(stream.wait)
+                            return waiter
                        else:
                            return waiter
                else: