|
if self.validate: |
|
assert ws is None or isinstance(ws, WorkerState), ( |
|
type(ws), |
|
ws, |
|
) |
|
assert ws.address in self.workers |
This bug makes everything crash with AttributeError whenever the top-level function decide_workers returns None.
However, no unit test (where validate=True) catches this.
distributed/distributed/scheduler.py
Lines 1951 to 1956 in 223c815
This bug makes everything crash with AttributeError whenever the top-level function
decide_workersreturns None.However, no unit test (where validate=True) catches this.