sciline.scheduler.DaskScheduler#

class sciline.scheduler.DaskScheduler(scheduler=None)[source]#

Wrapper for a Dask scheduler.

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

__init__(scheduler=None)[source]#

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)