$npx skillfedfor your agent

airflow-dag-patterns

Master production-grade Airflow DAG design with patterns for operators, sensors, and testing. Learn idempotent task design, dependency structures, and deployment strategies to orchestrate reliable data pipelines.

Airflow DAG Patterns teaches production-ready Apache Airflow design with best practices for operators, sensors, and testing.

AI-generated summary based on this skill's SKILL.md

38,308 4,097 MITupdated by wshobson

Decision gist · record as of 2026-07-22

Airflow DAG Patterns teaches production-ready Apache Airflow design with best practices for operators, sensors, and testing. Master production-grade Airflow DAG design with patterns for operators, sensors, and testing. Learn idempotent task design, dependency structures, and deployment strategies to orchestrate reliable data pipelines.

manual: git clone https://github.com/wshobson/agents → cp -r agents/plugins/data-engineering/skills/airflow-dag-patterns ~/.claude/skills/airflow-dag-patterns
plugins/data-engineering/skills/airflow-dag-patterns/SKILL.md · version bf76b000

Use it when

  • airflow-dag-patterns emphasizes production readiness through idempotent task design, robust error handling, and deployment strategies.
  • airflow-dag-patterns walks you through designing and orchestrating complete data pipelines.

Verify before relying

Read SKILL.md below before installing (2 files). Open directory: indexed for reading, not audited.

Same gist for agents: .md · .json

Install

wshobson/agents/airflow-dag-patterns · repository language: Python

Open directory. Skills are indexed for reading, not audited. Review a skill's body before installing it.

Frequently asked questions

AI-generated answers based on this skill's SKILL.md and metadata

How to build Apache Airflow DAGs with best practices?

airflow-dag-patterns teaches you to construct production-ready DAGs using proven design patterns. The skill covers structuring tasks with proper dependencies, implementing idempotent workflows, configuring retry logic and timeouts, and organizing code for maintainability. You'll learn to leverage the TaskFlow API, define clear task boundaries, and follow Airflow conventions for reliable orchestration.

What are airflow dag best practices for production deployment?

airflow-dag-patterns emphasizes production readiness through idempotent task design, robust error handling, and deployment strategies. Key practices include setting appropriate retry policies, using sensors effectively, structuring dependencies to prevent cascading failures, testing DAGs locally before production, and monitoring failed runs. The skill guides you through configuration patterns that ensure your workflows remain reliable at scale.

How do you create a data pipeline with Airflow?

airflow-dag-patterns walks you through designing and orchestrating complete data pipelines. You'll learn to define task sequences, connect operators for data extraction and transformation, use sensors to wait for external conditions, and structure XCom communication between tasks. The skill covers real ETL patterns, batch job scheduling, and how to compose operators and sensors into cohesive workflows.

What airflow operators and sensors should I implement?

airflow-dag-patterns teaches custom operator and sensor implementation alongside built-in options. You'll learn when to use standard operators versus building custom ones, how sensors reschedule or poke for readiness, and patterns for task communication. The skill covers sensor modes, operator inheritance, and practical examples of extending Airflow's capabilities for your specific pipeline needs.

How do you test and debug Airflow DAGs locally?

airflow-dag-patterns provides testing strategies for both local development and production environments. You'll learn to validate DAG structure, test individual tasks, simulate scheduling behavior, and debug failed runs. The skill covers tools for local testing, logging practices, and techniques to identify issues before deployment, ensuring your workflows behave correctly across environments.

How should task dependencies and idempotent workflows be configured?

airflow-dag-patterns covers dependency setup patterns that prevent race conditions and ensure correct execution order. You'll learn idempotent task design principles—making tasks safe to retry without side effects—and configuring catchup settings, retry logic, and timeouts. The skill teaches how to structure workflows so failures don't corrupt data and retries succeed reliably.

SKILL.md

Rendered from the published skill. Quoted content, verbatim.

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

```python

Linear

task1 >> task2 >> task3

Fan-out

task1 >> [task2, task3, task4]

Fan-in

[task1, task2, task3] >>

(truncated - see the full file via the links below)

File tree — 2 files
plugins/data-engineering/skills/airflow-dag-patterns/SKILL.md
plugins/data-engineering/skills/airflow-dag-patterns/references/details.md

Let your AI agent find skills like this

Example. Real query, live index.

You found this page by searching. An agent finds it by wishing: SkillFed indexes 56,283 agent skills by what they can do, searchable in plain language.

wish › “Build production-ready Apache Airflow DAGs with best practices”

Give your agent the search over MCP, or paste the wish link into any chat. No install? Search from any chat →

Related skills

Apache Airflow Orchestration
by manutej · manutej/luxor-claude-marketplace

Learn to architect and deploy data pipelines with Apache Airflow, covering DAG design, operators, task dependencies, branching logic, and scheduling patterns. This skill guides you through building scalable workflows from basic structures to advanced patterns like dynamic task generation and conditional execution. Deploy production-grade orchestration across single machines or distributed clusters.

no license declared → metadata onlyupdated Jun 2026
★ 61repo stars
airflow-expert
by personamanagmentlayer · personamanagmentlayer/pcl

airflow-expert provides deep knowledge for building reliable, scalable data pipelines with Airflow. Learn DAG fundamentals, task dependencies, branching logic, dynamic task generation, and production operations patterns to orchestrate complex workflows.

Apache-2.0updated Mar 2026
★ 38repo stars
airflow-dag
by datadrivenconstruction · datadrivenconstruction/DDC_Skills_for_AI_Agents_in_Construction

This skill generates Apache Airflow DAGs tailored for construction data workflows, handling everything from BIM model processing to validation and cost reporting. It provides a builder interface for composing tasks—bash commands, Python functions, file sensors, and branching logic—then outputs production-ready DAG code. Pre-built templates accelerate common patterns like BIM validation pipelines.

MITupdated Feb 2026
★ 254repo stars
ml-pipeline-automation
by secondsky · secondsky/claude-skills

Build production ML pipelines that handle data ingestion, model training, and deployment with Airflow DAGs, Kubeflow containers, and MLflow experiment tracking. This skill covers orchestration patterns, scheduling retraining jobs, managing model versions, and troubleshooting common workflow failures.

MITupdated Jul 2026
★ 196repo stars
ml-pipeline-workflow
by wshobson · wshobson/agents

ML Pipeline Workflow guides you through constructing production-ready MLOps systems that span data ingestion, preparation, model training, validation, and deployment. It covers pipeline architecture, DAG orchestration patterns, data quality checks, experiment tracking integration, and deployment strategies including canary and blue-green approaches.

MITupdated Jul 2026
★ 38,308repo stars
ML Pipeline Automation
by aj-geddes · aj-geddes/useful-ai-prompts

ML Pipeline Automation handles the complete machine learning lifecycle, automating data collection, preprocessing, model training, validation, and production deployment. Built on orchestration platforms like Airflow and Kubeflow, it ensures reproducible and scalable workflows with integrated monitoring and performance tracking.

MITupdated Mar 2026
★ 299repo stars
Tags
workflow-orchestrationdata-pipeline-designtask-schedulingdag-patternsairflow-operatorsbatch-processingproduction-deploymenterror-handling-retry