## Pipeline


An ordered chain of processing stages.


Usage

``` python
Pipeline(
    name="default",
    schema="v2",
)
```


## Parameters


`name: str = ``"default"`  
Pipeline identifier.

`schema: str = ``"v2"`  
Schema version string for reproducibility.


## Methods

| Name | Description |
|----|----|
| [add()](#add) | Append a stage to the pipeline. |
| [run()](#run) | Execute the pipeline synchronously. |
| [run_async()](#run_async) | Execute the pipeline asynchronously. |

------------------------------------------------------------------------


#### add()


Append a stage to the pipeline.


Usage

``` python
add(stage)
```


##### Parameters


`stage: Stage`  
The stage to add.


##### Returns


`Pipeline`  
Self, for chaining.


------------------------------------------------------------------------


#### run()


Execute the pipeline synchronously.


Usage

``` python
run()
```


##### Returns


`dict`  
Pipeline results keyed by stage name.


------------------------------------------------------------------------


#### run_async()


Execute the pipeline asynchronously.


Usage

``` python
run_async()
```


##### Returns


`dict`  
Pipeline results keyed by stage name.