1. Conduid
  2. Social
  3. io.github.us-all/airflow
MCP server · Social

io.github.us-all/airflow

· github.com/us-all/airflow-mcp-server

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

Unclaimed social
InstallView source
37Low

Scored 5 months ago · breakdown

About io.github.us-all/airflow

io.github.us-all/airflow is an MCP server in the Social category: airflow MCP — list DAGs/runs/task instances, tail logs, trigger and clear (write-gated).

Install

Claude Code
claude mcp add io-github-us-all-airflow -- npx -y @us-all/airflow-mcp
npx
npx -y @us-all/airflow-mcp

This server has no ConduID identity, so agent calls to it are not receipted. Pin the version you install and review the source before granting it credentials.

Tools (7)

airflow-clear-taskClear specific task instances → re-run (write-gated)

Parameters not published.

airflow-get-task-instancesTask instances for a specific DAG run

Parameters not published.

airflow-get-task-logsTail (last N kB) of one task instance log

Parameters not published.

airflow-list-dagsList active DAGs with tag/search filters

Parameters not published.

airflow-list-runsRecent runs of one DAG (state filter, ordered newest first)

Parameters not published.

airflow-trigger-dagTrigger a new run (write-gated)

Parameters not published.

dag-health-rollupAggregated DAG health: success rate + avg duration + last failed run + failing tasks

Parameters not published.

Ask AI

✦

Ask AI about io.github.us-all/airflow

Powered by Claude · Grounded in docs

I know everything about io.github.us-all/airflow. Ask me about installation, configuration, usage, or troubleshooting.

Security checks

  • ✓README presentThe repository ships documentation.

5 checks have not been run yet.

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

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

Run

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)

Tool Description
airflow-list-dags List active DAGs with tag/search filters
airflow-list-runs Recent runs of one DAG (state filter, ordered newest first)
airflow-get-task-instances Task instances for a specific DAG run
airflow-get-task-logs Tail (last N kB) of one task instance log
airflow-trigger-dag Trigger a new run (write-gated)
airflow-clear-task Clear specific task instances → re-run (write-gated)
dag-health-rollup Aggregated DAG health: success rate + avg duration + last failed run + failing tasks

meta

search-tools — natural-language tool discovery.

Prompts

Prompt Use 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

Env Required Notes
AIRFLOW_API_URL yes Airflow host base, e.g. http://airflow.example.com:8080. Trailing /api/v1 or /api/v2 is stripped if present
AIRFLOW_USERNAME yes Username for JWT minting via SimpleAuthManager /auth/token
AIRFLOW_PASSWORD yes Password for JWT minting (secret)
AIRFLOW_ALLOW_WRITE no true enables airflow-trigger-dag / airflow-clear-task
AIRFLOW_TOOLS / AIRFLOW_DISABLE no Category toggles

Tested-against schemas

  • Airflow 3.x /api/v2 (current default). Airflow 2.x is not supported by v0.2 because basic auth + /api/v1 were removed; pin to @us-all/airflow-mcp@0.1.0 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

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

License

MIT — see LICENSE.

README copy captured when this server was indexed; it may lag the repository. The original is authoritative.

Questions

About io.github.us-all/airflow

How do I install io.github.us-all/airflow?

Run claude mcp add io-github-us-all-airflow -- npx -y @us-all/airflow-mcp, then add the server to your MCP client's configuration.

Is io.github.us-all/airflow safe to use with an AI agent?

Its trust score is 37 out of 100 (low). It passes 1 of the 1 static security checks run so far. It has no ConduID identity yet, so agent calls to it are not receipted.

Is io.github.us-all/airflow still maintained?

Conduid hasn't recorded a commit date for this repository yet. Check the repository directly for recent activity.