cosmos-dbt-fusion

Run a dbt Fusion project with Astronomer Cosmos. Use when running a dbt Fusion project with Astronomer Cosmos (Cosmos 1.11+, ExecutionMode.LOCAL on Snowflake/Databricks). Before implementing, verify dbt engine is Fusion (not Core), the warehouse is supported, and local execution is acceptable. Does

By astronomer · 841 installs

npx skills add astronomer/agents --skill cosmos-dbt-fusion

Source repository · Upstream listing

Cosmos + dbt Fusion: Implementation Checklist Execute steps in order. This skill covers Fusion specific constraints only. Version note : dbt Fusion support was introduced in Cosmos 1.11.0. Requires Cosmos ≥1.11. Reference : See [reference/cosmos config.md](reference/cosmos config.md) for ProfileConfig, operator args, and Airflow 3 compatibility details. Before starting , confirm: (1) dbt engine = Fusion (not Core → use cosmos dbt core ), (2) warehouse = Snowflake, Databricks, Bigquery and Redshift only. Fusion Specific Constraints Constraint Details No async AIRFLOW ASYNC not supported No virtualenv Fusion is a binary, not a Python package Warehouse support Snowflake, Databricks, Bigquery and Redshift support [while in preview](https://github.com/dbt labs/dbt fusion) 1. Confirm Cosmos Version CRITICAL : Cosmos 1.11.0 introduced dbt Fusion compatibility. Validate : pip show astronomer cosmos reports version ≥ 1.11.0 2. Install the dbt Fusion Binary (REQUIRED) dbt Fusion is NOT bundled with Cosmos or dbt Core. Install it into the Airflow runtime/image. Determine where to install the Fusion binary (Dockerfile / base image / runtime). Example Dockerfile Install Common Install Paths Environment Typical path Astro Runtime /home/astro/.local/bin/dbt System wide /usr/local/bin/dbt Validate : The dbt binary exists at the chosen path and dbt version succeeds. 3. Choose Parsing Strategy (RenderConfig) Parsing strategy is the same as dbt Core. Pick ONE: Load mode When to use Required inputs dbt manifest Large projects; fastest parsing ProjectConfig.manifest path dbt ls Complex selectors; need dbt native selection Fusion binary accessible to scheduler automatic Simple setups; let Cosmos pick (none) 4. Configure Warehouse Connection (ProfileConfig) Reference : See [reference/cosmos config.md](reference/cosmos config.md profileconfig warehouse connection) for full ProfileConfig options and examples. 5. Configure ExecutionConfig (LOCAL Only) CRITICAL : dbt Fusion with Cosmos requires ExecutionMode.LOCAL with dbt executable path pointing to the Fusion binary. 6. Configure Project (ProjectConfig) 7. Assemble DAG / TaskGroup Option A: DbtDag (Standalone) Option B: DbtTaskGroup (Inside Existing DAG) 8. Final Validation Before finalizing, verify: [ ] Cosmos version : ≥1.11.0 [ ] Fusion binary installed : Path exists and is executable [ ] Warehouse supported : Snowflake, Databricks, Bigquery or Redshift only [ ] Secrets handling : Airflow connections or env vars, NOT plaintext Troubleshooting If user reports dbt Core regressions after enabling Fusion: User Must Test [ ] The DAG parses in the Airflow UI (no import/parse time errors) [ ] A manual run succeeds against the target warehouse (at least one model) Reference Cosmos dbt Fusion docs: https://astronomer.github.io/astronomer cosmos/configuration/dbt fusion.html dbt Fusion install: https://docs.getdbt.com/docs/core/pip install dbt fusion Related Skills cosmos dbt core : For dbt Core projects (not Fusion) authoring dags : General DAG authoring patterns testing dags : Testing DAGs after creation