Match incorrect existing behavior

dask · Sep 14, 2022 · f3de3b9 · f3de3b9
1 parent 7a6d4dc
commit f3de3b9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/distributed/scheduler.py b/distributed/scheduler.py
@@ -2847,7 +2847,11 @@ def _set_duration_estimate(self, ts: TaskState, ws: WorkerState) -> None:
         cpu = self.get_task_duration(ts)
         if exec_time > 2 * cpu:
             cpu = 2 * exec_time
-        network = self.get_comm_cost(ts, ws)
+            # FIXME this matches existing behavior but is clearly bizarre
+            # https://github.com/dask/distributed/issues/7003
+            network = 0.0
+        else:
+            network = self.get_comm_cost(ts, ws)
 
         old = ws.processing.get(ts, Occupancy(0, 0))
         ws.processing[ts] = new = Occupancy(cpu, network)