Dask Runner

class forml.provider.runner.dask.Runner(instance: asset.Instance | None = None, feed: io.Feed | None = None, sink: io.Sink | None = None, scheduler: str | None = None)[source]

Bases: Runner

ForML runner implementation using the Dask computing library as the execution platform.

Parameters:
scheduler: str | None = None

Name of the chosen Dask scheduler. Supported options are:

  • threaded

  • multiprocessing

The provider can be enabled using the following platform configuration:

config.toml
 [RUNNER.compute]
 provider = "dask"
 scheduler = "threaded"

Important

Select the dask extras to install ForML together with the Dask support.