pipeflow

A tiny declarative ETL pipeline built from a config dict.

from pipeflow import load_config

pipeline = load_config({"sources": [{"name": "users", "records": [{"id": 1}]}]})
pipeline.run()  # -> [{"id": 1}]