next#

caput.pipeline.Task.next(input=None)[source]#

Iterative analysis stage of pipeline task.

May be overridden with any number of positional only arguments (defaults are allowed). Pipeline data-products will be passed as specified by in keys in the pipeline setup.

Function will be called repetitively until it either raises a PipelineStopIteration or, if accepting inputs, runs out of input data-products.

Any return values will be treated as pipeline data-products as specified by the out keys in the pipeline setup.