Compat with py 3.10

2026-09-09 19:27:54 +02:00 · 2023-11-07 23:33:54 +00:00
parent 0c4d560281
commit a784d69487
1 changed files with 2 additions and 2 deletions
@@ -194,7 +194,7 @@ class Pregel(RunnableSerializable[dict[str, Any] | Any, dict[str, Any] | Any]):
                # execute tasks, and wait for one to fail or all to finish.
                # each task is independent from all other concurrent tasks
                done, inflight = concurrent.futures.wait(
-                    (
+                    [
                        executor.submit(
                            proc.invoke,
                            input,
@@ -209,7 +209,7 @@ class Pregel(RunnableSerializable[dict[str, Any] | Any, dict[str, Any] | Any]):
                            ),
                        )
                        for proc, input, _ in next_tasks
-                    ),
+                    ],
                    return_when=concurrent.futures.FIRST_EXCEPTION,
                    timeout=self.step_timeout,
                )