Update distributed/scheduler.py

dask · May 4, 2022 · e3d62f6 · e3d62f6
1 parent 01a0e8c
commit e3d62f6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/distributed/scheduler.py b/distributed/scheduler.py
@@ -2688,7 +2688,7 @@ def get_comm_cost(self, ts: TaskState, ws: WorkerState) -> float:
         for dts in deps:
             nbytes += dts.nbytes
         # Add a fixed 10ms penalty per transfer. See distributed#5324
-        return nbytes / self._bandwidth + 0.01 * len(deps)
+        return nbytes / self.bandwidth + 0.01 * len(deps)
 
     def get_task_duration(self, ts: TaskState) -> float:
         """Get the estimated computation cost of the given task (not including