Airflow

io.github.us-all由 GitHub 账号 us-all 发布v1.4.1更新于 Oct 25, 2026

Airflow MCP — list DAGs/runs/task instances, tail logs, trigger and clear (write-gated)

已验证STDIO仅桌面云端与基础设施数据与分析

概览

AI 生成的概览

面向 Apache Airflow 3.x 的 MCP 服务器，让助手列出 DAG、运行记录和任务实例、查看日志，并可选地触发或清除任务。

可以做什么
按标签和搜索条件列出活跃 DAG，并按状态筛选、从新到旧列出某个 DAG 的近期运行。获取指定 DAG 运行的任务实例，并查看某个任务实例日志的最后若干千字节。获取聚合的 DAG 健康汇总，包括成功率、平均时长、最近失败运行和失败任务。启用写入后可触发新的 DAG 运行并清除任务实例使其重跑。支持自然语言工具发现，并提供 DAG 失败排查和调度审计的内置提示词。
适用场景
适合运维 Airflow 流水线、希望助手在不打开 Airflow 界面的情况下检查 DAG 状态、根据日志诊断失败或查看各 DAG 成功率的场景。若需要在聊天客户端中偶尔触发或清除任务，可在明确启用写入后添加。
运行要求
通过 npm 包作为本地 Node.js 进程运行。需要 AIRFLOW_API_URL（仅主机地址）、AIRFLOW_USERNAME 和 AIRFLOW_PASSWORD 以通过 SimpleAuthManager 获取 JWT，并需要访问 Airflow 实例的网络。面向 Airflow 3.x 的 /api/v2；Airflow 2.x 需固定使用较旧的包版本。
安装前请注意
AIRFLOW_PASSWORD 是发送给 Airflow 主机以获取令牌的机密。设置 AIRFLOW_ALLOW_WRITE=true 会启用 trigger-dag 和 clear-task，从而启动和重跑流水线任务；只读使用时请勿设置。清除任务可能导致重复或意外的运行。该服务器还可切换为带 Bearer 认证的 HTTP 传输。

安装

在 SourceWeft 中

  1. 打开 控制台中的 Airflow，将其添加到工作区。
  2. 为需要使用其工具的对话启用该服务。

Desktop only，通过 STDIO。 STDIO 服务会启动本地进程，因此需要 SourceWeft 桌面宿主。

其他 MCP 客户端

参照 仓库 中的启动说明。

README

@us-all/airflow-mcp

Airflow MCP server — read DAGs, runs, task instances, log tails; trigger and clear (write-gated). Built on @us-all/mcp-toolkit.

A focused MCP for the Airflow 3.x REST API (/api/v2). Read by default; airflow-trigger-dag and airflow-clear-task are gated behind AIRFLOW_ALLOW_WRITE=true. Auth is JWT via SimpleAuthManager — supply AIRFLOW_USERNAME + AIRFLOW_PASSWORD and the server mints/refreshes the token transparently.

For deeper dbt integration (manifest parsing, run-results history, source freshness, per-column test coverage, lineage walks, custom DQ result tables), install the companion @us-all/dbt-mcp alongside.

  • 7 tools in airflow + meta categories
  • 2 MCP Prompts for DAG triage workflows
  • 1 aggregation tool that replaces the list-runs → get-task-instances combo

Install

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

Run

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

Pass the host base only — the server prepends /api/v2 internally. A trailing /api/v1 or /api/v2 is stripped if supplied. JWT tokens are cached for the lifetime of the session and refreshed 1 minute before they expire.

The server speaks MCP stdio; wire it into Claude Desktop / Cursor / any MCP client. Set MCP_TRANSPORT=http to opt in to Streamable HTTP transport (Bearer auth, /health endpoint).

Tools

airflow (6 + 1 aggregation)

ToolDescription
airflow-list-dagsList active DAGs with tag/search filters
airflow-list-runsRecent runs of one DAG (state filter, ordered newest first)
airflow-get-task-instancesTask instances for a specific DAG run
airflow-get-task-logsTail (last N kB) of one task instance log
airflow-trigger-dagTrigger a new run (write-gated)
airflow-clear-taskClear specific task instances → re-run (write-gated)
dag-health-rollupAggregated DAG health: success rate + avg duration + last failed run + failing tasks

meta

search-tools — natural-language tool discovery.

Prompts

PromptUse when
dag-failure-triage"Why did DAG X fail?" — pulls runs, isolates failure, dumps logs, proposes remediation
dag-schedule-audit"Sweep all DAGs for low success rate and stuck runs"

Environment variables

EnvRequiredNotes
AIRFLOW_API_URLyesAirflow host base, e.g. http://airflow.example.com:8080. Trailing /api/v1 or /api/v2 is stripped if present
AIRFLOW_USERNAMEyesUsername for JWT minting via SimpleAuthManager /auth/token
AIRFLOW_PASSWORDyesPassword for JWT minting (secret)
AIRFLOW_ALLOW_WRITEnotrue enables airflow-trigger-dag / airflow-clear-task
AIRFLOW_TOOLS / AIRFLOW_DISABLEnoCategory toggles

Tested-against schemas

  • Airflow 3.0–3.2 /api/v2 (verified against 3.2.1, current Airflow release as of 2026-05). Airflow 2.x is not supported by v0.2+ because basic auth + /api/v1 were removed; pin to @us-all/[email protected] for Airflow 2.x deployments.

Companion server

For dbt artifact parsing, run-results history, and DQ result tables, install @us-all/dbt-mcp alongside.

Build

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

License

MIT — see LICENSE.

来源：README.md，提交 486363a

工具

0
SourceWeft 尚未在沙箱中启动过该软件包，因此其工具未知。

版本历史

1
  1. v1.4.1最新Sep 16, 2026

评分

已满足适用检查项的 50%

该评分衡量此收录条目的完整程度，依据注册中心条目、端点与公开来源计算得出。它不是对服务器本身的评价，也不表示服务器安全或当前可用：可连通性是带日期的检查结果，评分也不包含安装量或用户评价。

  • 近 30 天内可连通25 分

    请保持端点能够响应 MCP 握手；SourceWeft 每 30 天探测一次。

  • 已声明认证方式10 分

    请在注册中心条目中声明凭据请求头，或保持端点能够响应探测，以便判定其认证方式。

  • 已列出工具15 分

    请让服务器在无凭据时响应 tools/list，或发布可在沙箱中无凭据启动的软件包。

  • 描述必需15 分
  • 图标10 分
  • 文档15 分
  • 许可证10 分