ska_sdp_piper.piper.runners.default_runner module

class ska_sdp_piper.piper.runners.default_runner.DefaultRunner(*, _pipeline_, **kwargs)[source]

The base runner class for sequential pipeline execution.

Parameters:

_pipeline_ (Pipeline) -- The pipeline instance
kwargs -- Any additional key-word arguments. In the Pipeline.run call, these kwargs are all of the cli arguments that were parsed by the pipeline.

Examples

>>> with DefaultRunner(_pipeline_=pipeline_instance) as runner:
...     runner.execute()

classmethod cli_args()[source]

Return an empty list of CLI arguments for the default runner.

Execute pipeline stages sequentially and log progress. This function is called by pipeline in its run subcommand.