Airflow MCP Server

Tools · 32

• list_dags List all DAGs in Airflow
• get_dag Get details of a specific DAG
• trigger_dag Trigger a DAG run
• get_dag_runs List DAG runs for a specific DAG
• get_dag_run Get details of a specific DAG run
• list_tasks List tasks for a specific DAG
• get_task Get details of a specific task
• get_task_instances List task instances for a DAG run
• get_task_instance Get details of a specific task instance
• list_connections List all connections
• create_connection Create a new connection
• get_connection Get details of a specific connection
• update_connection Update an existing connection
• delete_connection Delete a connection
• list_pools List all pools
• create_pool Create a new pool
• get_pool Get details of a specific pool
• update_pool Update an existing pool
• delete_pool Delete a pool
• list_variables List all variables
• create_variable Create a new variable
• get_variable Get details of a specific variable
• update_variable Update an existing variable
• delete_variable Delete a variable
• get_dag_source Get the source code of a DAG
• pause_dag Pause a DAG
• unpause_dag Unpause a DAG
• clear_dag_run Clear a DAG run
• set_task_instance_state Set the state of a task instance
• get_config Get Airflow configuration
• get_health Get Airflow health status
• get_version Get Airflow version