Airflow MCP Server

Tools · 29

• list_dags List all DAGs in Apache Airflow
• get_dag_details Get details of a specific DAG
• pause_dag Pause a DAG
• unpause_dag Unpause a DAG
• update_dag Update a DAG
• delete_dag Delete a DAG
• get_dag_source Get the source code of a DAG
• patch_multiple_dags Patch multiple DAGs at once
• reparse_dag_file Reparse a DAG file
• list_dag_runs List all DAG runs for a specific DAG
• create_dag_run Create a new DAG run
• get_dag_run_details Get details of a specific DAG run
• update_dag_run Update a DAG run
• delete_dag_run Delete a DAG run
• get_dag_runs_batch Get DAG runs in batch
• clear_dag_run Clear a DAG run
• set_dag_run_note Set a note on a DAG run
• get_upstream_dataset_events Get upstream dataset events for a DAG run
• list_dag_tasks List all tasks in a DAG
• get_task_details Get details of a specific task
• get_task_instance Get a specific task instance
• list_task_instances List task instances for a DAG run
• update_task_instance Update a task instance
• get_task_instance_log Get logs for a task instance
• clear_task_instances Clear task instances
• set_task_instances_state Set the state of task instances
• list_task_instance_tries List tries for a task instance
• list_variables List all variables
• create_variable Create a new variable