Skip to main content
Glama
deenesjakoruzh
us-all

airflow-mcp-server

by us-all
OverviewSchemaRelated ServersScoreDiscussions
TypeScript
Remote

@us-all/airflow-mcp

Servidor MCP de Airflow: lee DAGs, ejecuciones, instancias de tareas, logs; dispara y limpia (protegido contra escritura). Construido sobre @us-all/mcp-toolkit.

Un MCP enfocado en la API REST estable de Airflow. Lectura por defecto; airflow-trigger-dag y airflow-clear-task están protegidos detrás de AIRFLOW_ALLOW_WRITE=true.

Para una integración más profunda con dbt (análisis de manifiestos, historial de resultados de ejecución, frescura de fuentes, cobertura de pruebas por columna, recorridos de linaje, tablas de resultados de DQ personalizadas), instala el compañero @us-all/dbt-mcp junto a este.

  • 7 herramientas en las categorías airflow + meta

  • 2 Prompts de MCP para flujos de trabajo de triaje de DAGs

  • 1 herramienta de agregación que reemplaza la combinación list-runs → get-task-instances

Instalación

pnpm add -D @us-all/airflow-mcp

Ejecución

AIRFLOW_API_URL=http://airflow.example.com:8080/api/v1 \
AIRFLOW_USERNAME=admin AIRFLOW_PASSWORD=... \
npx @us-all/airflow-mcp

El servidor utiliza MCP stdio; conéctalo a Claude Desktop / Cursor / cualquier cliente MCP. Configura MCP_TRANSPORT=http para optar por el transporte HTTP transmitible (autenticación Bearer, endpoint /health).

Herramientas

airflow (6 + 1 agregación)

Herramienta

Descripción

airflow-list-dags

Lista DAGs activos con filtros de etiqueta/búsqueda

airflow-list-runs

Ejecuciones recientes de un DAG (filtro de estado, ordenadas de más reciente a más antigua)

airflow-get-task-instances

Instancias de tarea para una ejecución de DAG específica

airflow-get-task-logs

Tail (últimos N kB) del log de una instancia de tarea

airflow-trigger-dag

Dispara una nueva ejecución (protegido contra escritura)

airflow-clear-task

Limpia instancias de tarea específicas → re-ejecuta (protegido contra escritura)

dag-health-rollup

Salud agregada del DAG: tasa de éxito + duración promedio + última ejecución fallida + tareas fallidas

meta

search-tools — descubrimiento de herramientas mediante lenguaje natural.

Prompts

Prompt

Usar cuando

dag-failure-triage

"¿Por qué falló el DAG X?" — extrae ejecuciones, aísla el fallo, vuelca logs, propone remediación

dag-schedule-audit

"Revisar todos los DAGs en busca de baja tasa de éxito y ejecuciones bloqueadas"

Variables de entorno

Env

Requerido

Notas

AIRFLOW_API_URL

sí

Base de la API REST de Airflow, ej. http://airflow.example.com:8080/api/v1

AIRFLOW_USERNAME

no

Nombre de usuario para autenticación básica

AIRFLOW_PASSWORD

no

Contraseña para autenticación básica (secreto)

AIRFLOW_ALLOW_WRITE

no

true habilita airflow-trigger-dag / airflow-clear-task

AIRFLOW_TOOLS / AIRFLOW_DISABLE

no

Interruptores de categoría

Esquemas probados

  • API REST estable de Airflow (2.x). Airflow 3.x expone la misma superficie a través de los endpoints estables /api/v1/, por lo que este servidor funciona tanto con despliegues 2.x como 3.x.

Servidor complementario

Para el análisis de artefactos de dbt, historial de resultados de ejecución y tablas de resultados de DQ, instala @us-all/dbt-mcp junto a este.

Construcción

pnpm install
pnpm run build      # tsc → dist/
pnpm test           # vitest
pnpm run smoke      # spawns dist/index.js, calls initialize + tools/list (set env first)

Licencia

MIT — ver LICENSE.

Install Server
A
license - permissive license
A
quality
B
maintenance

How are these scores calculated?

Maintenance

–Maintainers
–Response time
0dRelease cycle
2Releases (12mo)

Resources

Unclaimed servers have limited discoverability.

Looking for Admin?

If you are the server author, to access and configure the admin panel.

Tools

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/us-all/airflow-mcp-server'

If you have feedback or need assistance with the MCP directory API, please join our Discord server