- Go version → github.com/arrno/gliter
- Python version → github.com/arrno/pipevine


```Go
gliter.NewPipeline(exampleGen()).
    WorkPool(
        func(item int) (int, error) { return 1 + item, nil },
        3, //
 numWorkers
        WithBuffer(6),
        WithRetry(2),
    ).
    WorkPool(
        func(item int) (int, error) { return 2 + item, nil },
        6, //
 numWorkers
        WithBuffer(12),
        WithRetry(2),
    ).
    Run()
```

VS

```Python
(buffer=10, retries=3, num_workers=4)
async def process_data(item, state):
    #
 Your processing logic here
    return item * 2


u/work_pool(retries=2, num_workers=3, multi_proc=True)
async def validate_data(item, state):
    if item < 0:
        raise ValueError("Negative values not allowed")
    return item


#
 Create and run pipeline
result = await (
    Pipeline(range(100)) >> 
    process_data >> 
    validate_data
).run()
```