mcp-airflow-simple
JSON →simple mcp server for Airflow 3 (API version 2)
Install
pip install -r Tools · 14
- get_dags List all DAGs in Airflow.
- get_dag_tasks Get all tasks in a specific DAG.
- trigger_dag_run Trigger a new DAG run.
- clear_dag_run Clear/retry a DAG run (resets failed tasks).
- set_dag_state Pause or unpause a DAG.
- get_dag_runs Get DAG run history with optional state filtering.
- get_task_instances Get task instances for a specific DAG run.
- get_dag_stats Get aggregate statistics for all DAGs.
- get_task_logs Get execution logs for a specific task instance.
- get_import_errors Get DAG import/parsing errors.
- get_connections List all Airflow connections.
- get_connection Get details of a specific connection.
- test_connection Test connection accessibility.
- check_health Check Airflow system health (includes Metadatabase, Scheduler, Triggerer, and DagProcessor).