Pipeline
A processing pipeline that manages a sequence of steps.
Usage
Pipeline()Parameters
name: str = "default"-
The name of this pipeline.
Methods
| Name | Description |
|---|---|
| add_step() | Add a step to the pipeline. |
| remove_step() | Remove a step from the pipeline. |
| reset() | Clear all steps from the pipeline. |
| run() | Execute all steps in the pipeline. |
add_step()
Add a step to the pipeline.
Usage
add_step(step)Call Pipeline.run() to execute.
Parameters
step: str-
The step identifier to add.
remove_step()
Remove a step from the pipeline.
Usage
remove_step(step)Parameters
step: str-
The step identifier to remove.
Returns
bool-
True if the step was found and removed.
reset()
Clear all steps from the pipeline.
Usage
reset()After calling this, use Pipeline.add_step() to add new steps.
Returns
None
run()
Execute all steps in the pipeline.
Usage
run()Use Pipeline.reset() to clear after running.
Returns
list-
Results from each step execution.