run

method of dascore.workflow.pipe.Pipe source

run(
    self ,
    *inputs ,
)-> ‘Any’

Run every task in order and return what the pipe’s outputs gave back.

Parameters

Parameter Description
*inputs What the pipe’s sources are given. A pipe with one source hands
it all of them. A pipe which branches takes one input per
branch, in the order they were wired, or a single input which
every branch is given. A pipe run with none is a pipe whose
sources make their own values.

Returns

The result of the pipe’s output, or a tuple of them in the order outputs lists if it has more than one.