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

Before Change

        // the first item in self._worker_procs is always considered to be the localhost, which is where
        // the router lives. The rest of the hosts will be considered as remote workers.
        try:
            self._worker_hosts = [x.rsplit(":", 1)[0] if ":" in x else get_localhost_ip() for x in self._worker_procs]
            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:

After Change

                    self._worker_hosts.append(worker_proc)
                    // here we assume that all nodes have the same number of cores so that we use
                    // the default value for master node for all computing nodes
                    self._max_workers.append(min(max(os.cpu_count() // 2, 2), 8))

            self._num_workers = [0 for x in self._worker_procs]
        except:

Instances