airflow

Develop, debug, and manage Apache Airflow v3 data pipelines.

9|Updated Feb 26, 2026
One-click install
npx skills add https://github.com/diegoscarabelli/system2 --skill airflow-diegoscarabelli
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: airflow
Source: https://github.com/diegoscarabelli/system2/tree/main/src/server/agents/skills/airflow
Command: npx skills add https://github.com/diegoscarabelli/system2 --skill airflow-diegoscarabelli

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This skill addresses the complexity of managing Apache Airflow v3 pipelines by providing a structured framework for DAG development, debugging, and operational best practices.

Core Features & Use Cases

  • Pipeline Lifecycle Management: Streamlines the creation, scheduling, and testing of DAGs using the modern Airflow SDK.
  • Error Handling & Debugging: Provides expert guidance on resolving common issues like task failures, scheduling bottlenecks, and XCom limitations.
  • Use Case: Use this skill to refactor legacy DAGs to the TaskFlow API, implement dynamic task mapping for parallel processing, or troubleshoot connection issues in production environments.

Quick Start

Use the airflow skill to analyze the current DAG file and suggest optimizations for task dependencies and execution efficiency.

Frequently Asked Questions about airflow

High-intent search queries and answers about installing and using this skill.

FAQPage Schema
How do I refactor legacy Airflow DAGs to the TaskFlow API?

Refactoring legacy Airflow DAGs to the TaskFlow API involves restructuring task dependencies using modern SDK decorators. This transition streamlines pipeline creation, scheduling, and testing while maintaining robust data engineering workflows.

How do I implement dynamic task mapping in Airflow for parallel processing?

Dynamic task mapping in Airflow allows you to generate parallel tasks at runtime based on input data. This skill guides you through scalable pipeline execution patterns to handle variable workloads efficiently within your DAGs.

What is the best way to troubleshoot Airflow task failures and scheduling bottlenecks?

Troubleshooting Airflow task failures and scheduling bottlenecks requires analyzing DAG execution logs and dependency configurations. This skill provides expert debugging guidance to resolve production-grade errors and optimize task scheduling.

How do I resolve XCom limitations in complex data pipelines?

Resolving XCom limitations in complex data pipelines requires managing data passing between tasks to avoid size constraints. This skill offers structured error handling and debugging strategies to address XCom bottlenecks effectively.

How do I manage Airflow connections in production environments?

Managing Airflow connections in production environments involves configuring secure credentials for external systems. This skill supports operational management tasks including connection setup and troubleshooting production deployment issues.

When should I use dynamic task mapping instead of standard task dependencies in Airflow?

Dynamic task mapping should be used instead of standard task dependencies in Airflow when processing variable-length input data that requires parallel execution. This approach ensures scalable and idempotent data engineering workflows.