sciline.scheduler.DaskScheduler

class sciline.scheduler.DaskScheduler(scheduler=None)

Wrapper for a Dask scheduler.

Note that this currently only works if all providers support posargs.

__init__(scheduler=None)

Wrap a dask scheduler or the default dask.threaded.get.

Parameters:

scheduler (Optional[Callable[..., Any]], default: None) – A Dask scheduler, such as dask.get, dask.threaded.get, dask.multiprocessing.get, or `dask.distributed.Client.get.

Methods

__init__([scheduler])	Wrap a dask scheduler or the default dask.threaded.get.
get(graph, keys[, reporter])