DistributedLocalClusterScheduler

class gordias.dask_setup.DistributedLocalClusterScheduler(threads_per_worker: int = 2, **kwargs: Any)

Scheduler using distributed.LocalCluster for local parallelism.

Recommended way to use on a single machine.

Parameters:

threads_per_worker (int, optional) – Number of threads per each worker.

cluster

A cluster of a scheduler and workers running on the local machine.

Type:

dask.LocalCluster

client

A client that connect to and submit computation to a Dask cluster.

Type:

dask.Client

Methods