What problem does it solve?
Testing Airflow DAGs often fails late and wastes time on slow, manual troubleshooting; this skill helps you run a DAG, capture the failure context, and iteratively fix issues until the pipeline succeeds.
Core Features & Use Cases
- Trigger-and-wait validation: Run a DAG run and wait for completion to quickly determine success vs failure.
- Targeted failure debugging: Retrieve run diagnostics and task logs for failed tasks, including retry attempts.
- Iterative fix-and-retest loop: Apply a fix and rerun using the same minimal workflow to converge on a working DAG.
Use case example: You deploy changes to a dbt/SQL-based Airflow DAG and it fails on a specific task; trigger the DAG, inspect logs for the failed task instance, apply the fix, and retest.
Quick Start
Ask the agent to test the DAG end-to-end by triggering and waiting for its completion using the Airflow entrypoint command, then debug only if it fails.