Skip to content

Commit

Permalink
Self-review
Browse files Browse the repository at this point in the history
  • Loading branch information
crusaderky committed Aug 24, 2022
1 parent 698ff22 commit 47e775f
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 4 deletions.
1 change: 1 addition & 0 deletions distributed/worker_state_machine.py
Original file line number Diff line number Diff line change
Expand Up @@ -564,6 +564,7 @@ class StealResponseMsg(SendMessageToScheduler):
@dataclass
class StateMachineEvent:
"""Base abstract class for all stimuli that can modify the worker state"""

__slots__ = ("stimulus_id", "handled")
#: Unique ID of the event
stimulus_id: str
Expand Down
9 changes: 5 additions & 4 deletions docs/source/scheduling-state.rst
Original file line number Diff line number Diff line change
Expand Up @@ -80,10 +80,11 @@ forgotten
dereferenced from the scheduler.

.. note::
There's no intermediate state between waiting ``waiting`` and `no-worker``: as soon
as a task has all of its dependencies in memory somewhere on the cluster, it is
immediately assigned to a worker. This can lead to very long task queues on the
workers, which are then rebalanced dynamically through :doc:`work-stealing`.
There's no intermediate state between ``waiting`` / ``no-worker`` and
``processing``: as soon as a task has all of its dependencies in memory somewhere on
the cluster, it is immediately assigned to a worker. This can lead to very long task
queues on the workers, which are then rebalanced dynamically through
:doc:`work-stealing`.

In addition to the literal state, though, other information needs to be
kept and updated about each task. Individual task state is stored in an
Expand Down

0 comments on commit 47e775f

Please sign in to comment.