Apache Airflow MCP connector
Updated
Apache Airflow is a platform for programmatically authoring, scheduling, and monitoring workflows through directed acyclic graphs (DAGs). The Apache Airflow MCP connector allows AI agents to manage DAGs and their configurations, create and test connections, and retrieve source code and configuration details. It also supports monitoring DAG warnings, tracking task status, and overseeing other Airflow resources across an instance.
Authentication type
- Basic Auth - Requires a username and password to be configured for the agent to access the service.
Uses
Use the Apache Airflow MCP connector to perform the following actions:
- Trigger and monitor workflow runs without manual intervention
- Diagnose failed tasks quickly using detailed run logs
- Manage connections to external systems securely
- Clear and rerun failed tasks to restore pipeline health
- Track task-level progress across complex workflows
- Add notes and context to workflow runs for team visibility
- Audit workflow configuration and connection settings
- Identify workflow warnings before they affect downstream processes
Example prompts
Use the following example prompts to invoke Apache Airflow MCP connector tools from your AI assistant or Boomi Connect workflow:
Show me all failed DAG runs from yesterday in Apache Airflow.Trigger the daily sales report DAG in Apache Airflow.List all connections configured in Apache Airflow.Clear the failed tasks in the customer sync DAG.What DAGs are currently paused in Apache Airflow?Get the logs for the last failed task in the billing pipeline.Check if the Salesforce connection in Apache Airflow is working.Show me all task instances for today's ETL run.Add a note to the latest DAG run explaining the delay.List all warnings for my DAGs in Apache Airflow.
Apache Airflow MCP connector tools
The Apache Airflow MCP connector provides the following tools. Each tool maps to a specific action you can invoke from your AI agent or automation.
| Tool | Description |
|---|---|
| get_config | Get current configuration |
| get_connections | List connections |
| post_connection | Create a connection |
| test_connection | Test a connection |
| delete_connection | Delete a connection |
| get_connection | Get a connection |
| patch_connection | Update a connection |
| get_dag_source | Get a source code |
| get_dag_warnings | List dag warnings |
| get_dags | List DAGs |
| patch_dags | Update DAGs |
| delete_dag | Delete a DAG |
| get_dag | Get basic information about a DAG |
| patch_dag | Update a DAG |
| post_clear_task_instances | Clear a set of task instances |
| get_dag_runs | List DAG runs |
| post_dag_run | Trigger a new DAG run |
| delete_dag_run | Delete a DAG run |
| get_dag_run | Get a DAG run |
| update_dag_run_state | Modify a DAG run |
| clear_dag_run | Clear a DAG run |
| set_dag_run_note | Update the DagRun note. |
| get_task_instances | List task instances |
| get_task_instance | Get a task instance |
| patch_task_instance | Updates the state of a task instance |
| get_extra_links | List extra links |
| get_mapped_task_instances | List mapped task instances |
| get_log | Get logs |
| set_task_instance_note | Update the TaskInstance note. |
| get_xcom_entries | List XCom entries |
| get_xcom_entry | Get an XCom entry |
| get_mapped_task_instance | Get a mapped task instance |
| patch_mapped_task_instance | Updates the state of a mapped task instance |
| set_mapped_task_instance_note | Update the TaskInstance note. |
| get_upstream_dataset_events | Get dataset events for a DAG run |
| get_dag_details | Get a simplified representation of DAG |
| get_tasks | Get tasks for DAG |
| get_task | Get simplified representation of a task |
| post_set_task_instances_state | Set a state of task instances |
| get_dag_runs_batch | List DAG runs (batch) |
| get_task_instances_batch | List task instances (batch) |
| get_datasets | List datasets |
| get_dataset_events | Get dataset events |
| get_dataset | Get a dataset |
| get_event_logs | List log entries |
| get_event_log | Get a log entry |
| get_health | Get instance status |
| get_import_errors | List import errors |
| get_import_error | Get an import error |
| get_permissions | List permissions |
| get_plugins | Get a list of loaded plugins |
| get_pools | List pools |
| post_pool | Create a pool |
| delete_pool | Delete a pool |
| get_pool | Get a pool |
| patch_pool | Update a pool |
| get_providers | List providers |
| get_roles | List roles |
| post_role | Create a role |
| delete_role | Delete a role |
| get_role | Get a role |
| patch_role | Update a role |
| get_users | List users |
| post_user | Create a user |
| delete_user | Delete a user |
| get_user | Get a user |
| patch_user | Update a user |
| get_variables | List variables |
| post_variables | Create a variable |
| delete_variable | Delete a variable |
| get_variable | Get a variable |
| patch_variable | Update a variable |
| get_version | Get version information |
