-
-
Notifications
You must be signed in to change notification settings - Fork 750
Closed
Closed
Copy link
Description
The task executing transitions should be migrated to the WorkerState event mechanism as outlined in #5736 (comment)
- The
Worker.executemethod is modified such that it no longer performs any transition but instead returns appropriateStateMachineEventsthat trigger the necessary handlers. For instance- TaskFinished
- Rescheduled
- TaskErred
- The
ensure_computingmethod is removed from the list ofhandle_commevery_cyclecallbacks - The logic of
ensure_computingis moved to a private method (perspectively a method of the new classWorkerState) - The new private method will not perform any transitions but rather return a list of recommendations
- This private method is then called as part of the transition system, e.g.
unpause handlertransition_waiting_readytransition_executing_*
- The implicit goal is to remove all invocations of
self.loop.add_callback(self.execute, ...)and replace this with the new callback method
Blocked by
Related work
Metadata
Metadata
Assignees
Labels
No labels