e3db6eaf05783a1682c66e24e288af3022789a2d,src/sos/workers.py,WorkerManager,__init__,#WorkerManager#Any#Any#,373

Before Change

    def __init__(self, worker_procs, backend_socket):
        self._worker_procs = worker_procs
        self._max_workers = int(self._worker_procs[0])

        self._local_workers = []
        self._num_local_workers = 0
        self._n_requested = 0

After Change

            self._max_workers = [int(x.rsplit(":", 1)[-1]) for x in self._worker_procs]
            self._num_workers = [0 for x in self._worker_procs]
        except:
            raise RuntimeError(f"Incorrect format for option -j ({self._worker_procs}), which should be one or more [host:]nproc")

        self._local_workers = []

        self._num_remote_workers = {}

Instances