WaitUntil

class caput.pipeline.tasklib.flow.WaitUntil

Bases: caput.pipeline.tasklib.base.MPILoggedTask

Wait until the requires key is received before forwarding inputs.

This simple synchronization task will forward on whatever inputs it gets, however, it won’t do this until it receives any requirement to it’s setup method. This allows certain parts of the pipeline to be delayed until a piece of data further up has been generated.

Methods

next(input_)	Immediately forward any input.
setup(input_)	Accept, but don't save any input.