Class Scheduler

A Remote Dask Scheduler controlled by SSH

Declaration

class Scheduler(Process)

address : str

The hostname where we should run this worker

connect_options : dict

kwargs to be passed to asyncssh connections

remote_python : str

Path to Python on remote node to run this scheduler.

kwargs : dict

These will be passed through the dask-scheduler CLI to the
dask.distributed.Scheduler class

▶ def __init__(self, address: str, connect_options: dict, kwargs: dict, remote_python=None) override
source link
This method overrides distributed.deploy.ssh.Process.__init__.