Airflow

Install

Works with Claude Code, Codex, VS Code, Cursor, Windsurf, Claude Desktop. Read the repository before you give any tool access to your data.

npx agentmarket install connector/us-all-airflow

About

No reviews yet. Installed it? Reviews come from verified installers only. How reviews work

Permissions

What this server can do and what it asks for, from its tool list and install config. Checked Oct 25, 2026.

Tools

15 read · 1 write · 1 delete

Secrets

1 (API keys, tokens or passwords)

Install scripts

Not scanned yet

Runs as

Node.js package

Tools (17)

Read from the source code; the running server may differ. Descriptions are the server’s own words; hidden characters are shown as [U+…].

• airflow-clear-task

  Clear specific task instances in an Airflow DAG run (re-run them); supports include_upstream / include_downstream. Write-gated by AIRFLOW_ALLOW_WRITE.

• airflow-get-asset

  Get one Airflow 3.x asset by numeric id, including producing tasks and consuming DAGs and the asset's extra metadata blob.

• airflow-get-task-instances

  List task instances for a specific Airflow DAG run with state, try_number, duration

• airflow-get-task-logs

  Fetch the tail (last N kB) of an Airflow task instance log for a specific try_number

• airflow-list-asset-events

  List Airflow 3.x asset materialization events (newest first by default). Each event names the source DAG/task/run plus any downstream DAG runs the materialization triggered. Filterable by assetId, sourceDagId, sourceRunId, sourceTaskId, and a timestamp window — pair with dbt-mcp lineage to trace cross-tool data flow.

• airflow-list-assets

  List Airflow 3.x assets (replaces the legacy 'dataset' concept) with optional URI substring filter and DAG-id filter. Returns producing tasks + consuming DAGs per asset — the cross-DAG lineage answer to 'who writes this, who reads this?'

• airflow-list-connections

  List Airflow connections (connection_id / conn_type / host / schema / login / port) — diagnose which external targets DAGs talk to. Passwords are never returned by the API.

• airflow-list-dag-warnings

  List non-fatal DAG warnings (e.g. references to a non-existent pool, duplicate task ids) optionally filtered by dagId or warningType. Newest first.

• airflow-list-dags

  List Airflow DAGs (active by default) with optional tag filter and dag_id substring search

• airflow-list-event-logs

  List the Airflow event-log audit trail (newest first): DAG run / task state changes, config edits, etc. Filterable by dagId, taskId, runId, event.

• airflow-list-import-errors

  List DAG files that failed to parse (import errors) with filename, timestamp, and stack trace — the first thing to check when a DAG is 'missing' from list-dags. Newest first.

• airflow-list-pools

  List Airflow pools with slot utilization (slots / occupied / running / queued / open) — diagnose why tasks are stuck queued due to pool capacity.

• airflow-list-runs

  List recent runs of one Airflow DAG, optionally filtered by state, ordered newest first

• airflow-list-variables

  List Airflow Variable keys + descriptions (values omitted to avoid leaking secrets) — see what configuration knobs exist.

• airflow-trigger-dag

  Trigger a new Airflow DAG run with optional conf payload and note. Write-gated by AIRFLOW_ALLOW_WRITE.

Signals

Stars

2

Forks

0

Open issues

0

Last commit

Jul 10, 2026 (3 months ago)

Last release

Jun 19, 2026 (4 months ago)

From GitHub (fetched Oct 24, 2026).

Details

Registry name

io.github.us-all/airflow

Version

1.4.1

Auth

API key

Packages

npm @us-all/airflow-mcp

License

MIT

Repository

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

First seen

Oct 24, 2026

Last checked

Oct 24, 2026

Source

Official MCP Registrygithub-graphql