tlpipe.pipeline.pipeline.PipelineStopIteration

exception tlpipe.pipeline.pipeline.PipelineStopIteration

This stops the iteration of next() in pipeline tasks.

Pipeline tasks should raise this exception in the next() method to stop the iteration of the task and to proceed to finish().

Note that if next() receives input data as an argument, it is not required to ever raise this exception. The pipeline will proceed to finish() once the input data has run out.