Dask Runner

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

Bases: Runner

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


Any Dask Configuration options.

Noteworthy parameters:
  • scheduler selects the scheduling implementation (valid options are: synchronous, threads, processes, distributed)

  • to submit to a remote Dask Cluster, set the scheduler to distributed and provide the master scheduler-address

The provider can be enabled using the following platform configuration:

 provider = "dask"
 scheduler = "processes"


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