Pipeline
An ordered chain of processing stages.
Usage
Pipeline()Parameters
name: str = "default"-
Pipeline identifier.
schema: str = "v2"-
Schema version string for reproducibility.
Methods
| Name | Description |
|---|---|
| add() | Append a stage to the pipeline. |
| run() | Execute the pipeline synchronously. |
| run_async() | Execute the pipeline asynchronously. |
add()
Append a stage to the pipeline.
Usage
add(stage)Parameters
stage: Stage-
The stage to add.
Returns
Pipeline-
Self, for chaining.
run()
Execute the pipeline synchronously.
Usage
run()Returns
dict-
Pipeline results keyed by stage name.
run_async()
Execute the pipeline asynchronously.
Usage
run_async()Returns
dict-
Pipeline results keyed by stage name.