Output

class caput.pipeline.extensions.Output(callback=None)

Bases: caput.pipeline._pipeline.Task

Take outputs from the pipeline and place them in a list.

To apply some processing to pipeline output (i.e. this tasks input), use the callback argument which will get passed the item. The return value of the callback is placed in the outputs attribute. Note that this need not be the input, so if pipeline output should be deleted to save memory you can simply return None.

Parameters:

callbackcallable() | None

A function which can apply some processing to the pipeline output.

Methods

next(→ None)

Append in_ to the outputs.