diff --git a/distributed/scheduler.py b/distributed/scheduler.py index 0508f04196..089da240f1 100644 --- a/distributed/scheduler.py +++ b/distributed/scheduler.py @@ -4593,7 +4593,7 @@ def update_graph( # TODO: balance workers def stimulus_queue_slots_maybe_opened(self, *, stimulus_id: str) -> None: - """Respond to an event which may have opened a spot on the threadpool of a worker + """Respond to an event which may have opened spots on worker threadpools Selects the appropriate number of tasks from the front of the queue according to the total number of task slots available on workers (potentially 0), and