This companion turns manuscript blocks 1-11 into the Airflow 3 baseline DAG plus the three split DAGs. Shared connections, Cosmos mapping, and the reverse-ETL push live in dags/techflow_common.py. It ...
In-process DuckDB storage extension: a catalog whose contents come from another DatabaseInstance in the same process, rather than from a file. A source instance exposes selected tables to a target ...