GatherInputs#

class caput.pipeline.tasklib.flow.GatherInputs[source]#

Bases: caput.pipeline.tasklib.base.MPILoggedTask

Gather an arbitrary number of inputs into a list.

The relevant number of inputs is determined by the task configuration keys.

Methods#

next(*inputs)

Gather the inputs into a list.