Avoid dask#7923 by starting run_id at 1

hendrikmakait · Jun 16, 2023 · 6bcc233 · 6bcc233
1 parent 4a0c489
commit 6bcc233
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/distributed/shuffle/_scheduler_extension.py b/distributed/shuffle/_scheduler_extension.py
@@ -34,7 +34,7 @@
 
 @dataclass
 class ShuffleState(abc.ABC):
-    _run_id_iterator: ClassVar[itertools.count] = itertools.count()
+    _run_id_iterator: ClassVar[itertools.count] = itertools.count(1)
 
     id: ShuffleId
     run_id: int