wshobson avatar

Airflow Dag Patterns

If you're building data pipelines with Airflow, this skill gives you production-ready DAG patterns that actually work in the real world. It covers TaskFlow API decorators for cleaner XCom passing, dynamic DAG generation from config files, proper branching with quality checks, and sensor patterns for external dependencies. The examples show concrete retry strategies, error handling, and testing approaches that prevent the common DAG antipatterns that break pipelines at 3am. Solid reference for both building new workflows and refactoring messy DAGs.

skills.sh installs
11.3K
GitHub stars
42.4K
last updated
Aug 21, 2026

Install

$ npx -y skills add wshobson/agents --skill airflow-dag-patterns --agent claude-code

Installs into .claude/skills of the current project.

Files

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

PrincipleDescription
IdempotentRunning twice produces same result
AtomicTasks succeed or fail completely
IncrementalProcess only new/changed data
ObservableLogs, metrics, alerts at every step

2. Task Dependencies

# Linear
task1 >> task2 >> task3

# Fan-out
task1 >> [task2, task3, task4]

# Fan-in
[task1, task2, task3] >> task4

# Complex
task1 >> task2 >> task4
task1 >> task3 >> task4

Quick Start

Sponsors

Details

Repository
github.com/wshobson/agents
Categories
Testing & QA, DevOps & CI/CD, Automation & Workflows

More from wshobson/agents

All 174
1wshobson avatardbt-transformation-patternswshobson/agentsMaster dbt (data build tool) for analytics engineering with model organization, testing, documentation, and incremental strategies. Use when building data trans11.3Kskills.sh installs
2aws avataraws-observabilityaws/agent-toolkit-for-awsBuilds, configures, debugs, and optimizes AWS observability with CloudWatch (Log Insights, Metrics, Alarms, Dashboards, EMF), X-Ray, CloudTrail, and ADOT (AWS D10.7Kskills.sh installs
3msw-git avatarmsw-scriptingmsw-git/msw-ai-coding-plugins-officialAuthoring MSW scripts (.mlua) plus integrated playtest and debugging. Covers mlua syntax, annotations (@Component/@Logic/@ExecSpace/@Sync), lifecycle, exec spac10.7Kskills.sh installs
4msw-git avatarmsw-combat-systemmsw-git/msw-ai-coding-plugins-officialMSW combat system integration guide. Covers the Attack→Hit pipeline, damage model, i-frame, knockback, Hit Stop, Camera Shake, Sprite Flash, SFX, death/revive, 10.6Kskills.sh installs
5phuryn avatarpre-mortemphuryn/pm-skillsRun a pre-mortem risk analysis on a PRD or launch plan. Categorizes risks as Tigers (real problems), Paper Tigers (overblown concerns), and Elephants (unspoken 10.5Kskills.sh installs
6github avatarai-prompt-engineering-safety-reviewgithub/awesome-copilotComprehensive AI prompt engineering safety review and improvement prompt. Analyzes prompts for safety, bias, security vulnerabilities, and effectiveness while p10.4Kskills.sh installs