Migrate ensure_computing
transitions to new WorkerState
event mechanism
#5895
Closed
3 tasks done
The task executing transitions should be migrated to the
WorkerState
event mechanism as outlined in #5736 (comment)Worker.execute
method is modified such that it no longer performs any transition but instead returns appropriateStateMachineEvents
that trigger the necessary handlers. For instanceensure_computing
method is removed from the list ofhandle_comm
every_cycle
callbacksensure_computing
is moved to a private method (perspectively a method of the new classWorkerState
)unpause handler
transition_waiting_ready
transition_executing_*
self.loop.add_callback(self.execute, ...)
and replace this with the new callback methodBlocked by
Related work
ensure_communicating
transitions to new WorkerState event mechanism #5896The text was updated successfully, but these errors were encountered: