ska_sdp_spectral_line_imaging.pipeline module

class ska_sdp_spectral_line_imaging.pipeline.CustomDaskRunner(pipeline, dask_scheduler=None, with_report=False, **kwargs)[source]

Bases: DaskRunner

execute()[source]

Execute pipeline stages sequentially and log progress.

Returns:

The output dictionary from the final pipeline stage.

Return type:

dict

ska_sdp_spectral_line_imaging.pipeline.pipeline_diagnostic(input_path, channel, output, dask_scheduler)[source]

Pipeline diagnostics sub_command

Parameters:

cli_args (argparse.Namespace) -- CLI arguments