Class SSHCluster

Declaration

class SSHCluster

▷ def __enter__(self)
source link
▷ def __exit__(self, *args)
source link
▶ def __init__(self, scheduler_addr, scheduler_port, worker_addrs, nthreads=0, nprocs=1, ...)
def __init__(
self,
scheduler_addr,
scheduler_port,
worker_addrs,
nthreads=0,
nprocs=1,
ssh_username=None,
ssh_port=22,
ssh_private_key=None,
nohost=False,
logdir=None,
remote_python=None,
memory_limit=None,
worker_port=None,
nanny_port=None,
remote_dask_worker="distributed.cli.dask_worker",
local_directory=None,
)
source link
▷ def add_worker(self, address)
source link
▷ def monitor_remote_processes(self)
source link
▷ def scheduler_address(self) @property
@property
def scheduler_address(self)
source link
▷ def shutdown(self)
source link