dataops-airflow-production-readiness

Audits Apache Airflow DAGs and deployments for production readiness.

14|1|Updated May 5, 2026
One-click install
npx skills add https://github.com/ivanshamaev/de-agent-skills --skill dataops-airflow-production-readiness
Or copy as Structured Prompt for Agent
Please help me install this Agent Skill.
Skill: dataops-airflow-production-readiness
Source: https://github.com/ivanshamaev/de-agent-skills/tree/main/group_skills/infra_dataops_group_skills/dataops_airflow_production_readiness
Command: npx skills add https://github.com/ivanshamaev/de-agent-skills --skill dataops-airflow-production-readiness

SYSTEM DOCUMENTATION & REQUIREMENTS

What problem does it solve?

This Skill helps you prepare an Apache Airflow deployment so production DAGs run reliably, avoid scheduler/metadata-database overload, and remain safe to re-execute without corrupting data.

Core Features & Use Cases

  • Idempotent task design: choose UPSERT or INSERT OVERWRITE patterns (including partition overwrite) so reruns don’t duplicate rows or produce inconsistent outputs.
  • DAG parse-time safety: prevent anti-patterns like Variable.get() at module/DAG parse time and keep heavy imports out of the global scope.
  • Operational production readiness: configure retries with exponential backoff, SLA callbacks, pools for throttling, KubernetesExecutor resources, metadata DB maintenance, and health checks.
  • Use Case: audit a newly added ETL DAG (e.g., orders -> bronze -> silver) and ensure each task can be safely retried, scales on Kubernetes, and alerts correctly when SLAs are missed.

Quick Start

Ask the AI to review your Airflow DAG code for production anti-patterns and provide concrete fixes for idempotency, parse-time database hits, retries/SLA, pools, KubernetesExecutor settings, and metadata DB maintenance.

Frequently Asked Questions about dataops-airflow-production-readiness

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

FAQPage Schema
How do I make Airflow DAGs safe for production reruns without duplicating data?

Airflow DAGs avoid scheduler overload and parse-time delays by preventing Variable.get() calls and heavy imports in the global scope. Moving database access and expensive libraries into task execution scope keeps DAG parsing fast and stable.

What is the best way to configure Airflow SLA alerts and retries for ETL pipelines?

The best way to configure Airflow SLA alerts and retries is to combine SLA callbacks for missed deadlines with robust retry policies using exponential backoff. This approach prevents silent pipeline failures and avoids overwhelming the scheduler.

Does KubernetesExecutor support resource limits and pool-based throttling for large-scale DAGs?

KubernetesExecutor supports resource limits and pool-based throttling for large-scale DAGs. Configuring executor resource limits and Airflow pools restricts concurrency, preventing metadata database overload during massive parallel task execution.

Why does my Airflow scheduler slow down when parsing large-scale DAG files?

Airflow scheduler slowdowns during large-scale DAG parsing often happen when DAG files access Variables or connections at module load time. Eliminating parse-time database hits keeps the scheduler responsive and prevents metadata database bottlenecks.

How do I maintain Airflow metadata database health for stable production deployments?

Maintaining Airflow metadata database health requires routine maintenance and health checks. Regularly cleaning old task instances and logs prevents database bloat, ensuring stable scheduler performance and reliable production operations.