Skip to content

[bug] Increasing workers size - missing variables during initialization #1032

Description

@jan-janssen

In the BlockAllocationTaskScheduler the workers are initialized with the following additional parameters:

{
    "worker_id": worker_id,
    "stop_function": lambda: _interrupt_bootup_dict[self_id],
    "bootup_event": bootup_events[worker_id],
    "next_bootup_event": (
        bootup_events[worker_id + 1]
        if worker_id + 1 < self._max_workers
        else None
    ),
    "alive_workers": alive_workers,
    "alive_workers_lock": alive_workers_lock,
}

But these additional parameters are not provided when the workers are rescaled using self.max_workers.

Metadata

Metadata

Assignees

No one assigned

    Labels

    bugSomething isn't working

    Type

    No type

    Fields

    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions