airflow-dag-patterns
Build production Apache Airflow DAGs with best practices for operators, sensors, testing, and deployment. Use when creating data pipelines, orchestrating workflows, or scheduling batch jobs.
By wshobson · 9,791 installs
npx skills add wshobson/agents --skill airflow-dag-patterns
Source repository · Upstream listing
Apache Airflow DAG Patterns
Production ready patterns for Apache Airflow including DAG design, operators, sensors, testing, and deployment strategies.
When to Use This Skill
Creating data pipeline orchestration with Airflow
Designing DAG structures and dependencies
Implementing custom operators and sensors
Testing Airflow DAGs locally
Setting up Airflow in production
Debugging failed DAG runs
Core Concepts
1. DAG Design Principles
Principle Description
Idempotent Running twice produces same result
Atomic Tasks succeed or fail completely
Incremental Process only new/changed data
Observable Logs, metrics, alerts at every step
2. Task Dependencies
Quick Start
Detailed patterns and worked examples
Detailed pattern documentation lives in references/details.md . Read that file when the navigation tier above is insufficient.
Best Practices
Do's
Use TaskFlow API Cleaner code, automatic XCom
Set timeouts Prevent zombie tasks
Use mode='reschedule' For sensors, free up workers
Test DAGs Unit tests and integration tests
Idempotent tasks Safe to retry
Don'ts
Don't use depends on past=True Creates bottlenecks
Don't hardcode dates Use {{ ds }} macros
Don't use global state Tasks should be stateless
Don't skip catchup blindly Understand implications
Don't put heavy logic in DAG file Import from modules