Skip to main content
Glama
biswasbiplob

mwaa-mcp-server

by biswasbiplob

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 exposed

  • Read-only by Default: Write operations require the --allow-write flag

  • Airflow 2.x and 3.x: The server detects each environment's Airflow major version and translates API differences (e.g. execution_date vs logical_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

uvx --from git+https://github.com/biswasbiplob/mwaa-mcp-server mwaa-mcp-server

Using pip

pip install git+https://github.com/biswasbiplob/mwaa-mcp-server

Using Docker

docker build -t mwaa-mcp-server .
docker run -it mwaa-mcp-server

Configuration

Environment Variables

Variable

Description

Default

AWS_REGION

AWS region for API calls

us-east-1

AWS_PROFILE

AWS CLI profile name

Default credential chain

MWAA_ENVIRONMENT

Default MWAA environment name (avoids per-call specification)

Auto-detect

FASTMCP_LOG_LEVEL

Log level (ERROR, WARNING, INFO, DEBUG)

WARNING

CLI Arguments

Argument

Description

--allow-write

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-environments

List all MWAA environments in the region

Read

get-environment

Get detailed information about an environment

Read

create-environment

Create a new MWAA environment

Write

update-environment

Update an existing MWAA environment

Write

delete-environment

Delete an MWAA environment

Write

Airflow Tools

Tool

Description

Access

list-dags

List all DAGs in an environment

Read

get-dag

Get details of a specific DAG

Read

get-dag-source

Get the source code of a DAG by DAG ID

Read

list-dag-runs

List DAG runs for a specific DAG

Read

get-dag-run

Get details of a specific DAG run

Read

list-task-instances

List task instances for a DAG run

Read

get-task-instance

Get details of a specific task instance (supports map_index for mapped tasks)

Read

list-mapped-task-instances

List all mapped instances of a dynamically mapped task

Read

get-task-logs

Get logs for a task instance try (supports pagination for large logs)

Read

list-connections

List Airflow connections (passwords redacted)

Read

list-variables

List Airflow variables (sensitive values redacted)

Read

get-import-errors

Get DAG import/parsing errors

Read

trigger-dag-run

Trigger a new DAG run

Write

pause-dag

Pause a DAG

Write

unpause-dag

Unpause a DAG

Write

clear-task-instances

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_token or create_web_login_token as tools. All Airflow API operations go through the AWS-native invoke_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-write is explicitly passed.

License

Apache-2.0

Install Server
A
license - permissive license
A
quality
B
maintenance

Maintenance

Maintainers
Response time
Release cycle
Releases (12mo)
Commit activity

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

  • A
    license
    C
    quality
    A
    maintenance
    Monitor 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-5dfdfb2
    54
    50
    MIT
  • A
    license
    A
    quality
    F
    maintenance
    An 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.
    31
    13
    Apache 2.0
  • A
    license
    -
    quality
    -
    maintenance
    An 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.

View all related MCP servers

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

View all MCP Connectors

Latest Blog Posts

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