foxes.utils.runners.DaskRunner(scheduler=None, n_workers=None, threads_per_worker=None, processes=True, cluster_args=None, client_args={}, progress_bar=True, verbosity=1)[source]

Constructor.

ParametersΒΆ

scheduler: str, optional

The dask scheduler choice

n_workers: int, optional

The number of workers for parallel run

threads_per_worker: int, optional

The number of threads per worker for parallel run

progress_bar: bool

Flag for showing progress bar

cluster_args: dict, optional

Explicit arguments for the cluster setup

client_args: dict, optional

Explicit arguments for the client setup

verbosity: int

The verbosity level, 0 = silent