diff --git a/distributed/scheduler.py b/distributed/scheduler.py index dad60dad42f..568b19a55a2 100644 --- 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)