runner

caput.pipeline.Manager.runner()

Main driver for the pipeline.

This function creates a generator object to initialize and run the pipeline. If self.interactive is True, or if breakpoint are set and enabled, the generator object will yield at the relevant pipeline stages. Otherwise, a single generator next call will run the pipeline to completion.

Returns:

pipeline_runnergenerator

Generator object to run the pipeline.

Raises:

PipelineRuntimeError

If a task stage returns the wrong number of outputs.