Annotate WorkerState variable instance

dask · Dec 9, 2020 · 3d493a6 · 3d493a6
1 parent a41ccbc
commit 3d493a6
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/distributed/scheduler.py b/distributed/scheduler.py
@@ -4657,6 +4657,7 @@ def decide_worker(self, ts: TaskState):
         """
         Decide on a worker for task *ts*.  Return a WorkerState.
         """
+        ws: WorkerState
         valid_workers: set = self.valid_workers(ts)
 
         if (