What is airflow-conditions-to-orchestra?

A conversion guide for moving Airflow's conditional task rules into Orchestra. Airflow is a tool for scheduling data workflows, and Orchestra uses condition expressions to decide whether tasks run.

Use it when converting Airflow DAGs that contain non-default trigger rules, branches, short-circuit tasks, or latest-only tasks into Orchestra YAML.

It removes the need to translate branching, skipped tasks, and upstream-result rules by guesswork. It explains how Airflow rules such as “run after one task succeeds” map to Orchestra conditions.

airflow-conditions-to-orchestra — Skill by orchestra-hq

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 airflow-conditions-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.

README.md

[![agentmods](https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airflow-conditions-to-orchestra/github.svg)](https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airflow-conditions-to-orchestra)

Your own site

<a href="https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airflow-conditions-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airflow-conditions-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.

Your own site · 80×15

<a href="https://agentmods.dev/skills/orchestra-hq/orchestra-skills/airflow-conditions-to-orchestra"><img src="https://agentmods.dev/badge/skills/orchestra-hq/orchestra-skills/airflow-conditions-to-orchestra.svg" alt="Reviewed on agentmods" width="80" height="20"></a>

Per session 92 Skills are progressive disclosure: only the name and description are preloaded; the body loads when the skill is used.

When invoked 2,584 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.

Model	Per session	Once invoked
Fable 5.1	$0.00092	$0.02584
Opus 5.5	$0.00037	$0.01034
Sonnet 5.5	$0.00018	$0.00517
Haiku 4.5	$0.00009	$0.00258

Measured 2mo ago against content hash ad428c3ae3f4, method: parsed. Prices are Anthropic first-party input rates as of 2026-10-07, from the pricing page.

Security

Grade A, and why

airflow-conditions-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 2mo 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/airflow-conditions-to-orchestra/SKILL.md · 274 lines

How it starts

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

Airflow Conditions → Orchestra Condition Expressions

Overview

Airflow controls conditional task execution through trigger_rule, BranchPythonOperator, and ShortCircuitOperator. Orchestra replaces all of these with condition: — a string expression evaluated per task or task group using ${{ expression }} syntax. The expression must evaluate to a truthy value for the task to run.

`trigger_rule` Mapping

Airflow's trigger_rule controls when a task runs relative to its upstream tasks. In Orchestra, the equivalent is a condition: expression on the task or group.

Airflow `trigger_rule`	Orchestra `condition:`	Notes
`all_success` (default)	`null`	Orchestra default — run only when all upstream succeed
`all_done`	(see below)	Run when all upstream finish regardless of status
`all_failed`	`"${{ task_groups['upstream'].all().status == 'FAILED' }}"`	Rarely used
`one_success`	`"${{ task_groups['upstream'].any().status == 'SUCCEEDED' }}"`
`one_failed`	`"${{ task_groups['upstream'].any().status == 'FAILED' }}"`
`none_failed`	`"${{ task_groups['upstream'].all().status != 'FAILED' }}"`	Run unless something failed
`none_skipped`	`"${{ task_groups['upstream'].all().status != 'SKIPPED' }}"`
`none_failed_min_one_success`	`"${{ task_groups['upstream'].any().status == 'SUCCEEDED' and task_groups['upstream'].all().status != 'FAILED' }}"`

`all_done` — special case

trigger_rule='all_done' means "run after all upstream finish, regardless of their status." In Orchestra this is expressed by simply not adding a condition — but you need to ensure Orchestra doesn't gate on success. The closest pattern is relying on depends_on at the stage level with treat_failure_as_warning: true on upstream tasks:

# Upstream task — mark failure as warning so downstream still runs
task-001:
  integration: AIRBYTE_CLOUD
  integration_job: AIRBYTE_CLOUD_JOB
  treat_failure_as_warning: true   # failure becomes WARNING, not FAILED
  ...

# Downstream task — no condition needed; runs after WARNING or SUCCESS
task-002:
  integration: DBT_CORE
  integration_job: DBT_CORE_EXECUTE
  depends_on:
    - task-001
  condition: null
  ...

Read the full file on GitHub · 274 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.

2mo ago First seen · 274 lines · 92 tokens per session scan A ad428c3ae3f4

Subscribe to this mod's changes

airflow-conditions-to-orchestra is a skill published in the GitHub repository orchestra-hq/orchestra-skills (9 stars, last pushed yesterday), licensed MIT. It adds 92 tokens to every session and 2,584 once invoked, about $0.0004 per session on Opus 5.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.

DevOps and cloud

airflow-conditions-to-orchestra next to 6 skills from other repositories
Mod	Type	Stars	Last push	Licence	Scan	Tokens	Works with
airflow-conditions-to-orchestraorchestra-hq/orchestra-skills	Skill	9	yesterday	MIT	A	92	Claude Code
imagegenopenai/codex	Skill	133k	yesterday	Apache-2.0	A	113	Codex
playwright-climicrosoft/playwright	Skill	99k	yesterday	Apache-2.0	A	19	Claude Code
local-ai-agentsmicrosoft/ai-agents-for-beginners	Skill	79k	4d ago	MIT	A	200	Claude Code, Codex
systematic-debuggingobra/superpowers	Skill	313k	3d ago	MIT	A	21	Claude Code
next-cache-components-adoptionvercel/next.js	Skill	143k	yesterday	MIT	A	95	Claude Code
next-partial-prefetching-adoptionvercel/next.js	Skill	143k	yesterday	MIT	A	103	Claude Code