mcpField
A
airflow

airflow

github.com/necatiarslanData & databases4447 installsUpdated 21w ago
Repository

About airflow

airflow is a skill for operating Airflow through the Airflow VS Code extension. It covers DAG management, run monitoring, and troubleshooting failures.

Key features

  1. 01List, pause, and resume DAGs
  2. 02Trigger and inspect DAG runs
  3. 03Analyze failed runs and logs
  4. 04View connections, variables, and server health

Use cases

  1. 01Check running DAGs and recent failures
  2. 02Track a run after triggering a DAG
  3. 03Investigate a failed run and its task logs

Install

Copy the command and run it in a terminal.

$npx skills add https://github.com/necatiarslan/airflow-vscode-extension --skill airflow

After installing, type/airflowin Claude Code to confirm it loaded.

Details

From the project README

Airflow Operations

Use the Airflow VS Code extension tools for all Airflow interactions. Avoid shell commands for Airflow operations.

Tool Quick Reference

ToolPurpose
list_active_dagsList active (unpaused) DAGs
list_paused_dagsList paused DAGs
get_running_dagsShow running or queued DAG runs
pause_dagPause a DAG
unpause_dagUnpause a DAG
trigger_dag_runTrigger a DAG run
get_dag_runsList DAG runs for a DAG
get_dag_historyDaily run history for a DAG
get_failed_runsFailed runs across DAGs
analyse_dag_latest_runFull analysis of latest run (tasks, logs, source)
get_dag_run_detailFull analysis of a specific run
get_dag_source_codeRetrieve DAG source code
go_to_dag_viewOpen DAG view panel
go_to_dag_log_viewOpen log view panel
go_to_connections_viewOpen connections panel
go_to_variables_viewOpen variables panel
go_to_providers_viewOpen providers panel
go_to_configs_viewOpen configs panel
go_to_plugins_viewOpen plugins panel
go_to_server_health_viewOpen server health panel

User Intent Patterns

DAG Operations
  • "List all DAGs" -> list_active_dags and list_paused_dags
  • "Show DAG source" -> get_dag_source_code
  • "Pause DAG X" -> pause_dag
  • "Resume DAG X" -> unpause_dag
Run Operations
  • "Trigger DAG X" -> trigger_dag_run
  • "Show recent runs" -> get_dag_runs
  • "Why did this fail?" -> analyse_dag_latest_run or get_dag_run_detail
Logs and Troubleshooting
  • "Show logs for task" -> go_to_dag_log_view or analyse_dag_latest_run
  • "Analyze latest run" -> analyse_dag_latest_run
System and Config
  • "Show connections" -> go_to_connections_view
  • "Show variables" -> go_to_variables_view
  • "Check server health" -> go_to_server_health_view

Common Workflows

Investigate a Failed Run
  1. Find failures: get_failed_runs
  2. Analyze latest run: analyse_dag_latest_run
  3. If a specific run ID is known: get_dag_run_detail
  4. Open logs if needed: go_to_dag_log_view
Trigger and Monitor
  1. Trigger: trigger_dag_run
  2. Check status: get_dag_runs
  3. Analyze if failed: analyse_dag_latest_run
Morning Health Check
  1. Check server health: go_to_server_health_view
  2. Check running DAGs: get_running_dags
  3. Review recent failures: get_failed_runs

Comments

Markdown supported