Faulty assert in Worker.transition_waiting_ready
Open
- Dominant language
- Python
- Stars
- 1.7k
- Forks
- 778
- Avg merge
- 2h 50m
- Merged PRs (30d)
- 3
Description
I think the assertion in https://github.com/dask/distributed/blob/d378b41a89e33e660257522dd4b86d44e6d15fc5/distributed/worker.py#L1464 is never true. `self.ready` will have priorities. Adding some logging
```
logger.warning('############# %s %s', key, self.ready)
```
ouptuts
```
43 distributed.worker[30125] WARNING ############# -3cc7458434b76e085f60ee2b4b3dc161 [((0, 1, 1, 0), '-77595a333c06d570fabf39dd72c3f0e5'), ((0, 1, 3, -1), '-3d83e26cf6671e58568f01886987f38b'), ((0, 1, 5, -2), '-e71accaf49023ba14850f58f99f5b81b')]
```
Contributor guide
Assessment
This issue has not been assessed yet.