dbt-core-airflow-to-orchestra

dbt-core-airflow-to-orchestra is a skill for Claude Code from orchestra-hq/orchestra-skills. It costs 137 tokens per session (2,795 once invoked), scanned A, original, MIT.

A conversion guide for moving Airflow tasks that run dbt Core into Orchestra. Airflow schedules and coordinates tasks, while dbt Core builds, tests, and updates data models from SQL and configuration files.

In plain words
What is it for?
Converting Airflow Bash, SSH, Python, Kubernetes, and Astronomer Cosmos tasks that run commands such as dbt run, build, test, seed, or snapshot.
Why use it?
It replaces several Airflow ways of launching the same dbt command with one matching Orchestra task. It also avoids preserving deployment details, such as an SSH wrapper, when the real work is running dbt.

Skill for Claude Code

Written for Claude Code: shipped in a Claude Code plugin.

Part of the migrate-to-orchestra plugin — 52 skills shipped together

Good fit Converting Airflow Bash, SSH, Python, Kubernetes, and Astronomer Cosmos tasks that run commands such as dbt run, build, test, seed, or snapshot.

Compare 6 skills from other repositories ↓
Install with agentmods
npx agentmods add skills/orchestra-hq/orchestra-skills/dbt-core-airflow-to-orchestra
Install

Getting it into your agent

One page per mod, every tool's command on it. A separate URL per tool would split the same page into five that compete with each other.

Any agent
npx skills add orchestra-hq/orchestra-skills --skill dbt-core-airflow-to-orchestra
Clone the repo
git clone --depth 1 https://github.com/orchestra-hq/orchestra-skills

Made for: Claude Code.

Or install migrate-to-orchestra, the plugin that ships this one along with the rest of its 52 skills.

Wrote this? Show the measurements

A badge with what this costs and how it scanned, read live from this page, so it follows the numbers instead of freezing them. Markdown for a README, HTML for a documentation site or a project page.

agentmods badge for dbt-core-airflow-to-orchestra

README.md
[![agentmods](https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/dbt-core-airflow-to-orchestra/github.svg)](https://agentmods.dev/skills/orchestra-hq/orchestra-skills/dbt-core-airflow-to-orchestra)
Your own site
<a href="https://agentmods.dev/skills/orchestra-hq/orchestra-skills/dbt-core-airflow-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/dbt-core-airflow-to-orchestra/github.svg" alt="Measured on agentmods" height="20"></a>

Or the 80×15 button, for a site that already has a row of RSS and ATOM ones. Only the verdict fits; the numbers stay here.

agentmods 80×15 button for dbt-core-airflow-to-orchestra

Your own site · 80×15
<a href="https://agentmods.dev/skills/orchestra-hq/orchestra-skills/dbt-core-airflow-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/dbt-core-airflow-to-orchestra.svg" alt="Reviewed on agentmods" width="80" height="20"></a>
Per session 137 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.
When invoked 2,795 The whole file, excluding the scripts and references it only reads on demand.
Security scan A 0 findings. A grade says what 26 rules found in the file — not that it is safe.
Origin original No closer match found in the catalogue.
Token cost

What it costs to keep this loaded

Counted locally with the o200k_base tokenizer, which is exact for GPT models; Claude uses its own tokenizer and its counts differ. Treat this as one consistent yardstick across the catalogue rather than a bill. Prices are per million input tokens.

ModelPer sessionOnce invoked
Fable 5.1 $0.00137 $0.02795
Opus 5 $0.00068 $0.01398
Sonnet 5 $0.00027 $0.00559
Haiku 4.5 $0.00014 $0.00280

Measured 12d ago against content hash 4c49951e2f55, method: parsed. Prices are Anthropic first-party input rates as of 2026-09-12, from the pricing page.

Security

Grade A, and why

dbt-core-airflow-to-orchestra scanned grade A with 0 findings against 26 rules in 11 categories — prompt injection, anti-refusal, data exfiltration, privilege escalation, supply chain, agent snooping, system-prompt leakage, SSRF and excessive agency — measured 12d ago.

A static scan of the body, not an audit. Every finding is printed with the line that produced it so you can judge whether it matters here. A mod is markdown that instructs an agent; that is exactly why what it instructs is worth reading.

Nothing flagged

None of the 26 patterns this scan looks for appear in this file: no shell pipes, no recursive deletes, no credential paths, no hidden text, no instruction-override or anti-refusal phrasing, no agent-config snooping. That is not a guarantee, it is the absence of the things that are checkable.

skills/migrate-to-orchestra/skills/dbt-core-airflow-to-orchestra/SKILL.md · 181 lines

How it starts

The opening of the file, as written. The whole thing — 181 lines — stays where its author put it; the contents beside it link to each section on GitHub.

dbt Core: Airflow → Orchestra Conversion

Overview

In Airflow, dbt Core is typically run via:

  • BashOperator executing dbt run / dbt build / etc.
  • SSHOperator SSH-ing into a remote server that runs dbt run / dbt build / etc.
  • KubernetesPodOperator running a dbt Docker image
  • Astronomer Cosmos (DbtTaskGroup, DbtRunOperator, etc.)

In Orchestra, dbt Core is a first-class integration. A single Execute task under DBT_CORE replaces one or more Airflow tasks. Orchestra pulls the dbt project from a connected Git repository and runs the commands you specify.

This applies no matter which operator wrapped the dbt call in Airflow. If the task body is a dbt CLI command (dbt run, dbt build, dbt test, dbt seed, dbt snapshot), convert it to DBT_CORE_EXECUTE — even if it arrived via SSHOperator against a remote dbt server. Don't fall back to a literal LINUX_SSH translation (see airflow-bash-ssh-to-orchestra) just because the source operator happens to be SSH-based; the SSH-server detail is an Airflow deployment artifact, not something to preserve. Point the converted task at an Orchestra dbt Core connection (Git repo + warehouse credentials) instead of the SSH connection.

Parameter Mapping

BashOperator with dbt CLI

Airflow / shell concept Orchestra YAML field Notes
bash_command (the dbt command string) parameters.commands Semicolon-separated list of dbt CLI commands
Python version in environment parameters.python_version e.g. '3.12'
pip / poetry / uv parameters.package_manager PIP, POETRY, or UV — infer from visible project files (poetry.lock/pyproject.tomlPOETRY, uv.lockUV, requirements.txt/PipfilePIP) or explicit invocations (poetry run dbt ..., uv run dbt ...). If none of that is visible, don't silently guess PIP — see Gotchas
Git repo + branch (where dbt project lives) connection: Orchestra dbt Core connection (stores Git repo URL + credentials)
--project-dir parameters.project_dir Subdirectory within the repo where dbt_project.yml lives — a real task parameter, not connection config. Leave null if the project is at the repo root; set it for monorepos (e.g. dbt/ or analytics/dbt_project)
--profiles-dir / profiles.yml Configured on Orchestra connection Set the warehouse connection on the dbt Core connection in Orchestra
--select / --exclude Include in parameters.commands e.g. dbt build --select models/marts
--target Include in command or set on connection e.g. dbt run --target prod
task_id name: Human-readable task name

Read the full file on GitHub · 181 lines

Changes

What this file has done since we first saw it

Hashed on every crawl. A supply-chain change to an agent config is a question of when, not whether, so the history is kept rather than the latest state alone.

  1. 12d ago First seen · 181 lines · 137 tokens per session scan A 4c49951e2f55

Subscribe to this mod's changes

dbt-core-airflow-to-orchestra is a skill published in the GitHub repository orchestra-hq/orchestra-skills (9 stars, last pushed 3d ago), licensed MIT. It adds 137 tokens to every session and 2,795 once invoked, about $0.0007 per session on Opus 5. A static security scan graded it A with 0 findings. No closer match exists in the catalogue, so it is treated as the original; first seen 2026-08-31.

Related

Other skills, from other repositories

pinecone

Managed vector DB for production RAG and search.

NousResearch/hermes-agent · 13 tokens

embeddings

Vector embeddings with HNSW indexing, sql.js persistence, and hyperbolic support. 75x faster with agentic-flow integration. Use when: semantic search, pattern matching, similarity queries, knowledge retrieval. Skip when: exact text matching, simple lookups, no semantic understanding needed.

ruvnet/ruflo · 62 tokens

data-engineer

Build scalable data pipelines, modern data warehouses, and real-time streaming architectures. Implements Apache Spark, dbt, Airflow, and cloud-native data platforms.

davila7/claude-code-templates · 35 tokens

graphjin-env

Use when setting up a training or evaluation loop against a GraphJin agent environment — running the container, reading /health, driving episodes hosted or step-by-step or with your own agent over MCP, splitting train from eval, exporting trajectories, and deciding whether two rewards can be compared.

dosco/graphjin · 61 tokens

ingesting-into-data-lake

Import data into the AWS data lake from S3 files, local uploads, JDBC databases (Oracle, SQL Server, PostgreSQL, MySQL, RDS, Aurora), Amazon Redshift, Snowflake, BigQuery, DynamoDB, or existing Glue catalog tables (migration). Default target is S3 Tables; standard Iceberg on a general purpose bucket is supported where…

aws/agent-toolkit-for-aws · 228 tokens

similarity-search-patterns

Implement efficient similarity search with vector databases. Use when building semantic search, implementing nearest neighbor queries, or optimizing retrieval performance.

foryourhealth111-pixel/Vibe-Skills · 30 tokens