Pipeline#

Qualified name: rsm.app.Pipeline

class rsm.app.Pipeline(tasks)[source]#

Bases: None

A sequence of Task instances executed one after the other.

Methods

`add_task`	Add a task at the end of the current pipeline.
`pop_task`	Remove and return the last task.
`run`	Execute every task in the pipeline serially.

add_task(task)[source]#

Add a task at the end of the current pipeline.

pop_task()[source]#

Remove and return the last task.

run(initial_args=None)[source]#

Execute every task in the pipeline serially.