ska_sdp_piper.piper.runners.dask_runner module

class ska_sdp_piper.piper.runners.dask_runner.DaskRunner(*, dask_scheduler=None, with_report=False, **kwargs)[source]

Bases: DefaultRunner

A runner that executes pipelines using Dask for distributed computation.

Parameters:

dask_scheduler (str | None, default: None) -- The address of the Dask scheduler.
with_report (bool, default: False) -- Whether to generate a Dask performance report.
**kwargs -- Additional keyword arguments for the DefaultRunner.

additional = []

classmethod cli_args()[source]

Return the combined list of mandatory and additional CLI arguments.

Returns:: The list of CLIArgument objects for the runner.
Return type:: list