Class Worker
A Remote Dask Worker controled by SSH
Declaration
source linkDocumentation
Attributes
- scheduler : str
The address of the scheduler
- address : str
The hostname where we should run this worker
- worker_module : str
The python module to run to start the worker.
- connect_options : dict
kwargs to be passed to asyncssh connections
- remote_python : str
Path to Python on remote node to run this worker.
- kwargs : dict
These will be passed through the dask-worker CLI to the
dask.distributed.Worker class
Methods
▶ def __init__(self, scheduler: str, address: str, connect_options: dict, kwargs: dict, ...) override def __init__(
self,
scheduler: str,
address: str,
connect_options: dict,
kwargs: dict,
worker_module="distributed.cli.dask_worker",
remote_python=None,
loop=None,
name=None,
)
This method overrides distributed.deploy.ssh.Process.__init__.