annotating-task-lineage

Queries data warehouses to answer business questions by executing SQL, finding tables, and retrieving precise metrics and trends.

Manages Apache Airflow operations via the af CLI (installed via uvx from astro-airflow-mcp), including listing, testing, running, and debugging DAGs, viewing task logs, checking connections and variables, and monitoring system health. Supports multi-instance configuration with auto-discovery of Astro and local deployments.

Guides developers in creating robust Apache Airflow DAGs using best practices and MCP tools.

Systematically diagnoses Airflow DAG failures by performing deep root cause analysis, identifying error sources, and providing structured prevention recommendations.

Guides users through migrating Apache Airflow 2.x projects to Airflow 3.x, addressing code changes, imports, operators, and compatibility issues.

Triggers and monitors Airflow DAG runs, automatically waiting for completion and providing immediate feedback on success or failure.

Traces data origins by investigating DAGs, source tables, and external systems to map the complete upstream lineage of a data asset.

Data profiling agent skills for deep-dive table analysis including metadata inspection, column-level statistics, and data quality assessment using SQL queries.

Traces downstream data dependencies to reveal potential impacts and risks when modifying tables or data pipelines.

Skill for managing local Airflow environments with Astro CLI, covering start/stop/restart, log viewing, container troubleshooting, and environment issue fixing