Fix var name in worker validation func (#4457)

gforsyth · web-flow · commit 3a94ebc12b39 · 2021-01-25T16:00:31.000-06:00
diff --git a/distributed/worker.py b/distributed/worker.py
@@ -3007,7 +3007,7 @@ def validate_state(self):
                     assert (
                         ts_wait.state == "flight"
                         or ts_wait.state == "waiting"
-                        or ts.wait.key in self._missing_dep_flight
+                        or ts_wait.key in self._missing_dep_flight
                         or ts_wait.who_has.issubset(self.in_flight_workers)
                     )
                 if ts.state == "memory":

Original file line number	Diff line number	Diff line change
`@@ -3007,7 +3007,7 @@ def validate_state(self):`
`3007`	`3007`	`assert (`
`3008`	`3008`	`ts_wait.state == "flight"`
`3009`	`3009`	`or ts_wait.state == "waiting"`
`3010`		`- or ts.wait.key in self._missing_dep_flight`
	`3010`	`+ or ts_wait.key in self._missing_dep_flight`
`3011`	`3011`	`or ts_wait.who_has.issubset(self.in_flight_workers)`
`3012`	`3012`	`)`
`3013`	`3013`	`if ts.state == "memory":`