Module deploy

Re-exported Classes

class Adaptive
Adaptively allocate workers based on scheduler load. A superclass.
[distributed.deploy.adaptive.Adaptive]
class Cluster
Superclass for cluster objects
[distributed.deploy.cluster.Cluster]
class LocalCluster
Create local Scheduler and Workers
[distributed.deploy.local.LocalCluster]
class ProcessInterface
An interface for Scheduler and Worker processes for use in SpecCluster
[distributed.deploy.spec.ProcessInterface]
class SpecCluster
Cluster that requires a full specification of workers
[distributed.deploy.spec.SpecCluster]

def SSHCluster(hosts: List[str] = None, connect_options: Union[List[dict], dict] = {}, worker_options: dict = {}, scheduler_options: dict = {}, worker_module: str = "distributed.cli.dask_worker", remote_python: Union[str, List[str]] = None, **kwargs)
Deploy a Dask cluster using SSH
[distributed.deploy.ssh.SSHCluster]