Skip to content

Commit

Permalink
Add "ready->memory" to transitions in worker
Browse files Browse the repository at this point in the history
This should remove the error message in dask#4721 but is more of a band-aid
than a fix.  Ready->memory transitions shouldn't happen, but since they
do occassionally crop up, we might as well dispatch them appropriately
until the worker state machine is ready.
  • Loading branch information
gforsyth committed Apr 21, 2021
1 parent f492aa7 commit e575383
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions distributed/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -466,6 +466,8 @@ def __init__(
("executing", "memory"): self.transition_executing_done,
("flight", "memory"): self.transition_flight_memory,
("flight", "fetch"): self.transition_flight_fetch,
# Shouldn't be a valid transition but happens nonetheless
("ready", "memory"): self.transition_ready_memory,
# Scheduler intercession (re-assignment)
("fetch", "waiting"): self.transition_fetch_waiting,
("flight", "waiting"): self.transition_flight_waiting,
Expand Down

0 comments on commit e575383

Please sign in to comment.