next#

caput.pipeline.tasklib.flow.AccumulateList.next(input_)[source]#

Append an input to the list of inputs.

Parameters:
input_Any

Arbitrary input to accumulate.

Returns:
outputlist[Any] | None

If group_size is None, nothing is returned until this task reaches finish(). Otherwise, return a list of length group_size.