PassOn#

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

Unconditionally forward a tasks input.

While this seems like a pointless no-op it’s useful for connecting tasks in complex topologies.

Methods#

next(input_)

Immediately forward any input.