caput.pipeline.tasklib.flow#

Simple pipeline tasks used to control how data flows through the pipeline.

Classes#

AccumulateList

Accumulate the inputs into a list and return as a group.

Delete

Delete pipeline products to free memory.

GatherInputs

Gather an arbitrary number of inputs into a list.

MakeCopy

Make a copy of the passed object.

PassOn

Unconditionally forward a tasks input.

WaitUntil

Wait until the requires key is received before forwarding inputs.