Increase rootish dependencies

dask · Sep 18, 2024 · 927d36a · 927d36a
1 parent 8bafad5
commit 927d36a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/distributed/scheduler.py b/distributed/scheduler.py
@@ -3090,8 +3090,8 @@ def is_rootish(self, ts: TaskState) -> bool:
         # TODO short-circuit to True if `not ts.dependencies`?
         return (
             len(tg) > self.total_nthreads * 2
-            and len(tg.dependencies) < 5
-            and sum(map(len, tg.dependencies)) < 5
+            and len(tg.dependencies) < 100
+            and sum(map(len, tg.dependencies)) < 500
         )
 
     def check_idle_saturated(self, ws: WorkerState, occ: float = -1.0) -> None: