ska_sdp_batchlet.utils.pipeline_executer module

class ska_sdp_batchlet.utils.pipeline_executer.PipelineExecuter[source]

Bases: object

Pipeline Executor

static run(monitor_handler, command)[source]

Run pipeline

Parameters:

  • monitor_handler (MonitorHandler) -- Instance of MonitorHandler. This is used to get stream objects to watch stdout of the subprocess

  • command (list[str]) -- Command to be executed within the dask cluster