mwaa-mcp-server
Provides management capabilities for Amazon MWAA environments, including listing, describing, creating, updating, and deleting environments.
Allows interaction with Apache Airflow within Amazon MWAA, including DAG operations, DAG run monitoring, task instance management, connection and variable access, and retrieving import errors.
Click on "Install Server".
Wait a few minutes for the server to deploy. Once ready, it will show a "Started" state.
In the chat, type
@followed by the MCP server name and your instructions, e.g., "@mwaa-mcp-serverShow me the recent DAG runs for the etl_dag"
That's it! The server will respond to your query, and you can continue using it as needed.
Here is a step-by-step guide with screenshots.
mwaa-mcp-server
A Model Context Protocol (MCP) server for Amazon Managed Workflows for Apache Airflow (MWAA).
Features
MWAA Environment Management: List, describe, create, update, and delete MWAA environments
Airflow DAG Operations: List DAGs, view details, get source code, trigger runs, pause/unpause
DAG Run Monitoring: List and inspect DAG runs, task instances, and task logs
Configuration Access: View Airflow connections (with password redaction) and variables
Error Diagnostics: Retrieve DAG import/parsing errors
Secure by Design: All Airflow API operations go through AWS
invoke_rest_api— no CLI or web tokens are exposedRead-only by Default: Write operations require the
--allow-writeflagAirflow 2.x and 3.x: The server detects each environment's Airflow major version and translates API differences (e.g.
execution_datevslogical_date) transparently — tools keep one stable interface
Related MCP server: astro-airflow-mcp
Prerequisites
Python 3.10+
AWS credentials configured (via environment variables, AWS CLI profile, or IAM role)
An Amazon MWAA environment (Airflow 2.x or 3.x)
Installation
Using uvx (recommended)
uvx --from git+https://github.com/biswasbiplob/mwaa-mcp-server mwaa-mcp-serverUsing pip
pip install git+https://github.com/biswasbiplob/mwaa-mcp-serverUsing Docker
docker build -t mwaa-mcp-server .
docker run -it mwaa-mcp-serverConfiguration
Environment Variables
Variable | Description | Default |
| AWS region for API calls |
|
| AWS CLI profile name | Default credential chain |
| Default MWAA environment name (avoids per-call specification) | Auto-detect |
| Log level (ERROR, WARNING, INFO, DEBUG) |
|
CLI Arguments
Argument | Description |
| Enable write operations (trigger DAG runs, pause/unpause DAGs, create/update/delete environments) |
Usage with Claude Desktop
Add to your Claude Desktop MCP configuration:
{
"mcpServers": {
"mwaa-mcp-server": {
"command": "uvx",
"args": ["--from", "git+https://github.com/biswasbiplob/mwaa-mcp-server", "mwaa-mcp-server"],
"env": {
"AWS_REGION": "us-east-1",
"AWS_PROFILE": "my-profile",
"MWAA_ENVIRONMENT": "my-environment",
"FASTMCP_LOG_LEVEL": "INFO"
}
}
}
}For write access:
{
"mcpServers": {
"mwaa-mcp-server": {
"command": "uvx",
"args": ["--from", "git+https://github.com/biswasbiplob/mwaa-mcp-server", "mwaa-mcp-server", "--allow-write"],
"env": {
"AWS_REGION": "us-east-1",
"AWS_PROFILE": "my-profile",
"MWAA_ENVIRONMENT": "my-environment",
"FASTMCP_LOG_LEVEL": "INFO"
}
}
}
}Tool Reference
Environment Management Tools
Tool | Description | Access |
| List all MWAA environments in the region | Read |
| Get detailed information about an environment | Read |
| Create a new MWAA environment | Write |
| Update an existing MWAA environment | Write |
| Delete an MWAA environment | Write |
Airflow Tools
Tool | Description | Access |
| List all DAGs in an environment | Read |
| Get details of a specific DAG | Read |
| Get the source code of a DAG by DAG ID | Read |
| List DAG runs for a specific DAG | Read |
| Get details of a specific DAG run | Read |
| List task instances for a DAG run | Read |
| Get details of a specific task instance (supports | Read |
| List all mapped instances of a dynamically mapped task | Read |
| Get logs for a task instance try (supports pagination for large logs) | Read |
| List Airflow connections (passwords redacted) | Read |
| List Airflow variables (sensitive values redacted) | Read |
| Get DAG import/parsing errors | Read |
| Trigger a new DAG run | Write |
| Pause a DAG | Write |
| Unpause a DAG | Write |
| Clear task instances for a DAG, allowing re-runs | Write |
IAM Permissions
Minimum Read-only Policy
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"airflow:GetEnvironment",
"airflow:ListEnvironments",
"airflow:InvokeRestApi"
],
"Resource": "*"
}
]
}Full Access Policy (Read + Write)
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Action": [
"airflow:GetEnvironment",
"airflow:ListEnvironments",
"airflow:CreateEnvironment",
"airflow:UpdateEnvironment",
"airflow:DeleteEnvironment",
"airflow:InvokeRestApi"
],
"Resource": "*"
}
]
}Security
No token exposure: Unlike other MWAA tools, this server does not expose
create_cli_tokenorcreate_web_login_tokenas tools. All Airflow API operations go through the AWS-nativeinvoke_rest_api.Password redaction: Connection passwords and extra fields are automatically redacted in responses.
Variable redaction: Variable values with sensitive keys (matching patterns like
secret,password,token,api_key) are automatically redacted.Input validation: Environment names and path parameters are validated to prevent injection.
Read-only by default: Write operations are disabled unless
--allow-writeis explicitly passed.
License
Apache-2.0
Maintenance
Resources
Unclaimed servers have limited discoverability.
Looking for Admin?
If you are the server author, to access and configure the admin panel.
Related MCP Servers
- AlicenseCqualityAmaintenanceMonitor and manage Apache Airflow clusters through natural language queries via MCP tools: DAG inspection, task monitoring, health checks, and cluster analytics without API complexity. * Guide: https://call518.medium.com/mcp-airflow-api-a-model-context-protocol-mcp-server-for-apache-airflow-5dfdfb25450MIT

astro-airflow-mcpofficial
AlicenseAqualityFmaintenanceAn MCP server that enables AI assistants to interact with Apache Airflow's REST API for DAG management, task monitoring, and system diagnostics. It provides comprehensive tools for triggering workflows, retrieving logs, and inspecting system health across Airflow 2.x and 3.x versions.3113Apache 2.0- Alicense-quality-maintenanceAn MCP server that wraps the Apache Airflow REST API, enabling clients to manage DAGs, monitor task instances, and handle workflows through a standardized interface. It provides comprehensive access to Airflow features including DAG runs, variables, connections, and XComs.
- AlicenseAqualityAmaintenanceMCP server exposing Apache Airflow REST API operations as tools — list DAGs, inspect runs and task instances, trigger DAG runs, and check failed DAGs and scheduler health72MIT
Related MCP Connectors
Hosted Amazon Seller and Vendor MCP server for Claude, ChatGPT, Cursor, Codex, Gemini, Copilot.
Hosted Amazon Seller Central and Amazon Ads MCP server for Claude, ChatGPT, Cursor, and agents.
Official Microsoft MCP Server to query Microsoft Entra data using natural language
Latest Blog Posts
- Who's Calling? MCP Hosts Are an Identity Blind Spot (And the Spec Knows It)By Om-Shree-0709 on .mcpAgent IdentityOAuth 2.1
- Your AI Chatbot Just Exposed Your CEO's Salary to an InternBy Om-Shree-0709 on .Agent IdentityMCP SecurityOAuth Delegation
- Why MCP Servers Need Execution Sandboxing (And Why Your Current Stack Isn't Enough)By Om-Shree-0709 on .Agentic AiPrompt InjectionWebAssembly
MCP directory API
We provide all the information about MCP servers via our MCP API.
curl -X GET 'https://glama.ai/api/mcp/v1/servers/biswasbiplob/mwaa-mcp-server'
If you have feedback or need assistance with the MCP directory API, please join our Discord server