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
todistributed
and provide the masterscheduler-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.