Examples

Browse runnable examples grouped by category. Each page includes a short setup and how to run.

Connectors

• Postgres Fan-Out: dynamic fan-out (concurrent queries), schema setup (SQLAlchemy or raw SQL), and summary upsert — see examples/postgres_fanout.md.
• ADLS2 CSV Roundtrip: create container, write/read CSV, and clean up — see examples/adls2_csv_roundtrip.md.

Core patterns

See examples/general_examples.md for these patterns: - ETL mini‑pipeline with dynamic fan‑out - Caching and priority - Secrets usage - Timeout and retry - ArtifactRef handling - Custom tracing - Threaded parallelism

Testing

Guidance on testing flows/tasks — see testing.md.