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.

Parameters:

**kwargs¶

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:

config.toml¶

 [RUNNER.compute]
 provider = "dask"
 scheduler = "processes"

Important

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