Input#

class caput.pipeline.extensions.Input(inputs=None)[source]#

Bases: caput.pipeline._pipeline.Task

Pass inputs into the pipeline from outside.

Methods#

next()

Pop and return successive inputs.