class forml.provider.runner.dask.Runner(instance: asset.Instance | None =
None, feed: io.Feed | None =
None, sink: io.Sink | None =
ForML runner implementation using the Dask computing library as the execution platform.
Any Dask Configuration options.
- Noteworthy parameters:
schedulerselects the scheduling implementation (valid options are:
to submit to a remote Dask Cluster, set the
distributedand provide the master
The provider can be enabled using the following platform configuration:
[RUNNER.compute] provider = "dask" scheduler = "processes"
daskextras to install ForML together with the Dask support.