class foxes.utils.runners.DaskRunner(foxes.utils.runners.Runner)[source]

Class for function execution via dask


scheduler: str, optional

The dask scheduler choice

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

Public members

DaskRunner(scheduler=None, n_workers=None, ...)[source]


classmethod is_distributed()[source]

Initialize the runner

print(*args, **kwargs)[source]

Prints if verbosity is not zero

run(func, args=(), kwargs={})[source]

Runs the given function.


Finallize the runner

property initialized

Initialization flag