Class for function execution via dask

Attributes¶

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]

Constructor.

classmethod is_distributed()[source]

initialize()[source]

Initialize the runner

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

Prints if verbosity is not zero

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

Runs the given function.

finalize()[source]

Finallize the runner

property initialized

Initialization flag