Каталог MCP
yangkyeongmo@/mcp-server-apache-airflow

yangkyeongmo@/mcp-server-apache-airflow

MCP-сервер для Apache Airflow управляет DAG, запускает задачи, настраивает переменные и мониторит выполнение через единый протокол. Полезен инженерам данных и DevOps для автоматизации CI/CD.

README

68 инструментов

Версии

Установить сервер

mcp-server-apache-airflow

PyPI - Downloads

A Model Context Protocol (MCP) server implementation for Apache Airflow, enabling seamless integration with MCP clients. This project provides a standardized way to interact with Apache Airflow through the Model Context Protocol.

About

This project implements a Model Context Protocol server that wraps Apache Airflow's REST API, allowing MCP clients to interact with Airflow in a standardized way. It uses the official Apache Airflow client library to ensure compatibility and maintainability.

Feature Implementation Status

Feature	API Path	Status
DAG Management
List DAGs	`/api/v1/dags`	✅
Get DAG Details	`/api/v1/dags/{dag_id}`	✅
Pause DAG	`/api/v1/dags/{dag_id}`	✅
Unpause DAG	`/api/v1/dags/{dag_id}`	✅
Update DAG	`/api/v1/dags/{dag_id}`	✅
Delete DAG	`/api/v1/dags/{dag_id}`	✅
Get DAG Source	`/api/v1/dagSources/{file_token}`	✅
Patch Multiple DAGs	`/api/v1/dags`	✅
Reparse DAG File	`/api/v1/dagSources/{file_token}/reparse`	✅
DAG Runs
List DAG Runs	`/api/v1/dags/{dag_id}/dagRuns`	✅
Create DAG Run	`/api/v1/dags/{dag_id}/dagRuns`	✅
Get DAG Run Details	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}`	✅
Update DAG Run	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}`	✅
Delete DAG Run	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}`	✅
Get DAG Runs Batch	`/api/v1/dags/~/dagRuns/list`	✅
Clear DAG Run	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/clear`	✅
Set DAG Run Note	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/setNote`	✅
Get Upstream Dataset Events	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/upstreamDatasetEvents`	✅
Tasks
List DAG Tasks	`/api/v1/dags/{dag_id}/tasks`	✅
Get Task Details	`/api/v1/dags/{dag_id}/tasks/{task_id}`	✅
Get Task Instance	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}`	✅
List Task Instances	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances`	✅
Update Task Instance	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}`	✅
Get Task Instance Log	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/logs/{task_try_number}`	✅
Clear Task Instances	`/api/v1/dags/{dag_id}/clearTaskInstances`	✅
Set Task Instances State	`/api/v1/dags/{dag_id}/updateTaskInstancesState`	✅
List Task Instance Tries	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/tries`	✅
Variables
List Variables	`/api/v1/variables`	✅
Create Variable	`/api/v1/variables`	✅
Get Variable	`/api/v1/variables/{variable_key}`	✅
Update Variable	`/api/v1/variables/{variable_key}`	✅
Delete Variable	`/api/v1/variables/{variable_key}`	✅
Connections
List Connections	`/api/v1/connections`	✅
Create Connection	`/api/v1/connections`	✅
Get Connection	`/api/v1/connections/{connection_id}`	✅
Update Connection	`/api/v1/connections/{connection_id}`	✅
Delete Connection	`/api/v1/connections/{connection_id}`	✅
Test Connection	`/api/v1/connections/test`	✅
Pools
List Pools	`/api/v1/pools`	✅
Create Pool	`/api/v1/pools`	✅
Get Pool	`/api/v1/pools/{pool_name}`	✅
Update Pool	`/api/v1/pools/{pool_name}`	✅
Delete Pool	`/api/v1/pools/{pool_name}`	✅
XComs
List XComs	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries`	✅
Get XCom Entry	`/api/v1/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task_id}/xcomEntries/{xcom_key}`	✅
Datasets
List Datasets	`/api/v1/datasets`	✅
Get Dataset	`/api/v1/datasets/{uri}`	✅
Get Dataset Events	`/api/v1/datasetEvents`	✅
Create Dataset Event	`/api/v1/datasetEvents`	✅
Get DAG Dataset Queued Event	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents/{uri}`	✅
Get DAG Dataset Queued Events	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents`	✅
Delete DAG Dataset Queued Event	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents/{uri}`	✅
Delete DAG Dataset Queued Events	`/api/v1/dags/{dag_id}/dagRuns/queued/datasetEvents`	✅
Get Dataset Queued Events	`/api/v1/datasets/{uri}/dagRuns/queued/datasetEvents`	✅
Delete Dataset Queued Events	`/api/v1/datasets/{uri}/dagRuns/queued/datasetEvents`	✅
Monitoring
Get Health	`/api/v1/health`	✅
DAG Stats
Get DAG Stats	`/api/v1/dags/statistics`	✅
Config
Get Config	`/api/v1/config`	✅
Plugins
Get Plugins	`/api/v1/plugins`	✅
Providers
List Providers	`/api/v1/providers`	✅
Event Logs
List Event Logs	`/api/v1/eventLogs`	✅
Get Event Log	`/api/v1/eventLogs/{event_log_id}`	✅
System
Get Import Errors	`/api/v1/importErrors`	✅
Get Import Error Details	`/api/v1/importErrors/{import_error_id}`	✅
Get Health Status	`/api/v1/health`	✅
Get Version	`/api/v1/version`	✅

Инструменты были проиндексированы: 11.09.2026

clear_dag_run

Очистить запуск DAG

Очищает запуск DAG

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
dry_runboolean | null

clear_task_instances

Очистить набор экземпляров задач

Очищает экземпляры задач.

Параметры

dag_idstringобязательный
dry_runboolean | null
end_datestring | null
include_downstreamboolean | null
include_futureboolean | null
include_parentdagboolean | null
include_pastboolean | null
include_subdagsboolean | null
include_upstreamboolean | null
reset_dag_runsboolean | null
start_datestring | null
task_idsstring[] | null

create_connection

Создать подключение

Параметры

conn_idstringобязательный
conn_typestringобязательный
extrastring | null
hoststring | null
loginstring | null
passwordstring | null
portinteger | null
schemastring | null

create_dataset_event

Создать событие набора данных

Параметры

dataset_uristringобязательный
extraobject | null

create_variable

Создаёт переменную

Создать переменную

Параметры

descriptionstring | null
keystringобязательный
valuestringобязательный

delete_connection

Удалить соединение по ID

Удалить подключение

Параметры

conn_idstringобязательный

delete_dag

Удалить DAG

Удалить Dag

Параметры

dag_idstringобязательный

delete_dag_dataset_queued_event

Удалить поставленное в очередь событие Dataset для DAG

Событие постановки удаления Dag Dataset в очередь

Параметры

dag_idstringобязательный
uristringобязательный

delete_dag_dataset_queued_events

Удалить поставленные в очередь события Dataset для DAG

Удаляет события, поставленные в очередь, для набора данных Dag.

Параметры

beforestring | null
dag_idstringобязательный

delete_dag_run

Удаляет запуск DAG по DAG ID и DAG run ID.

Удалить запуск DAG

Параметры

dag_idstringобязательный
dag_run_idstringобязательный

delete_dataset_queued_events

Удаляет события в очереди для набора данных Dataset

Удаляет события, стоящие в очереди набора данных.

Параметры

beforestring | null
uristringобязательный

delete_pool

Удалить пул

Параметры

pool_namestringобязательный
The pool name.

delete_variable

Удалить переменную по ключу

Удалить переменную

Параметры

keystringобязательный

fetch_dags

Получить все DAGs

Получить DAG

Параметры

dag_id_patternstring | null
limitinteger | null
offsetinteger | null
only_activeboolean | null
order_bystring | null
pausedboolean | null
tagsstring[] | null

get_config

Получает текущую конфигурацию

Get Config

Параметры

sectionstring | null

get_connection

Получить соединение по ID

Получает подключение.

Параметры

conn_idstringобязательный

get_dag

Получить DAG по ID

Получает Dag.

Параметры

dag_idstringобязательный

get_dag_dataset_queued_event

Получить событие Dataset, поставленное в очередь, для DAG

Получает событие постановки датасета DAG в очередь.

Параметры

dag_idstringобязательный
uristringобязательный

get_dag_dataset_queued_events

Получить события Dataset в очереди для DAG

Получает события очереди наборов данных DAG.

Параметры

dag_idstringобязательный

get_dag_details

Получить упрощенное представление DAG

Получить детали Dag

Параметры

dag_idstringобязательный
fieldsstring[] | null

get_dag_run

Получить запуск DAG по DAG ID и DAG run ID

Получает Dag Run.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный

get_dag_runs

Получить запуски DAG по ID

Получить запуски DAG

Параметры

dag_idstringобязательный
end_date_gtestring | null
end_date_ltestring | null
execution_date_gtestring | null
execution_date_ltestring | null
limitinteger | null
offsetinteger | null
order_bystring | null
start_date_gtestring | null
start_date_ltestring | null
statestring[] | null
updated_at_gtestring | null
updated_at_ltestring | null

get_dag_runs_batch

Список запусков DAG (пакетно)

Получает пакет запусков DAG.

Параметры

dag_idsstring[] | null
end_date_gtestring | null
end_date_ltestring | null
execution_date_gtestring | null
execution_date_ltestring | null
order_bystring | null
page_limitinteger | null
page_offsetinteger | null
start_date_gtestring | null
start_date_ltestring | null
statestring[] | null

get_dag_source

Получить исходный код

Получает исходный код Dag.

Параметры

file_tokenstringобязательный

get_dag_stats

Получить статистику DAG

Получи статистику Dag.

Параметры

dag_idsstring[] | null

get_dag_tasks

Получить задачи для DAG

Получает задачи DAG.

Параметры

dag_idstringобязательный

get_dataset

Получает набор данных по URI

Получает набор данных.

Параметры

uristringобязательный

get_dataset_events

Получить события датасета

Получает события набора данных.

Параметры

dataset_idinteger | null
limitinteger | null
offsetinteger | null
order_bystring | null
source_dag_idstring | null
source_map_indexinteger | null
source_run_idstring | null
source_task_idstring | null

get_dataset_queued_events

Получить события в очереди для Dataset

Получить события в очереди набора данных

Параметры

uristringобязательный

get_datasets

Список наборов данных

Получает наборы данных.

Параметры

dag_idsstring | null
limitinteger | null
offsetinteger | null
order_bystring | null
uri_patternstring | null

get_event_log

Получить конкретную запись лога по ID

Получает журнал событий.

Параметры

event_log_idintegerобязательный

get_event_logs

Вывести записи из журнала событий.

Получает журналы событий.

Параметры

afterstring | null
beforestring | null
dag_idstring | null
eventstring | null
excluded_eventsstring | null
included_eventsstring | null
limitinteger | null
map_indexinteger | null
offsetinteger | null
order_bystring | null
ownerstring | null
run_idstring | null
task_idstring | null
try_numberinteger | null

get_health

Получить статус инстанса

Get Health

Параметры

Без параметров.

get_import_error

Получить конкретную ошибку импорта по ID

Получает ошибку импорта.

Параметры

import_error_idintegerобязательный

get_import_errors

Вывести список ошибок импорта

Получает ошибки импорта.

Параметры

limitinteger | null
offsetinteger | null
order_bystring | null

get_log

Получить логи экземпляра задачи по DAG ID, task ID, DAG run ID и task try number

Получает журнал.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
task_idstringобязательный
task_try_numberintegerобязательный

get_plugins

Получить список загруженных плагинов.

Получить плагины

Параметры

limitinteger | null
The numbers of items to return.
offsetinteger | null
The number of items to skip before starting to collect the result set.

get_pool

Получить пул по имени

Get Pool

Параметры

pool_namestringобязательный
The pool name.

get_pools

Список пулов

Получает пулы.

Параметры

limitinteger | null
The numbers of items to return.
offsetinteger | null
The number of items to skip before starting to collect the result set.
order_bystring | null
The name of the field to order the results by. Prefix a field name with - to reverse the sort order.

get_providers

Получить список загруженных провайдеров

Get Providers

Параметры

limitinteger | null
The numbers of items to return.
offsetinteger | null
The number of items to skip before starting to collect the result set.

get_task

Получить задачу по ID

Получить задачу

Параметры

dag_idstringобязательный
task_idstringобязательный

get_task_instance

Получает экземпляр задачи по DAG ID, task ID и DAG run ID.

Получает экземпляр задачи.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
task_idstringобязательный

get_tasks

Получить задачи для DAG

Получает задачи

Параметры

dag_idstringобязательный
order_bystring | null

get_upstream_dataset_events

Получить события датасета для запуска DAG

Получает события вышестоящего набора данных.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный

get_value

Получить конкретный параметр из конфигурации

Получает значение.

Параметры

optionstringобязательный
sectionstringобязательный

get_variable

Получить переменную по ключу

Получает переменную.

Параметры

keystringобязательный

get_version

Получить информацию о версии

Получает версию.

Параметры

Без параметров.

get_xcom_entries

Получить все записи XCom

Получает записи Xcom

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
limitinteger | null
map_indexinteger | null
offsetinteger | null
task_idstringобязательный
xcom_keystring | null

get_xcom_entry

Получить запись XCom

Получает запись Xcom.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
deserializeboolean | null
map_indexinteger | null
stringifyboolean | null
task_idstringобязательный
xcom_keystringобязательный

list_connections

Вывести список всех подключений

Перечисляет соединения.

Параметры

limitinteger | null
offsetinteger | null
order_bystring | null

list_task_instances

Вывести список экземпляров задач по ID DAG и ID запуска DAG.

Перечисляет экземпляры задач.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
duration_gtenumber | null
duration_ltenumber | null
end_date_gtestring | null
end_date_ltestring | null
execution_date_gtestring | null
execution_date_ltestring | null
limitinteger | null
offsetinteger | null
poolstring[] | null
queuestring[] | null
start_date_gtestring | null
start_date_ltestring | null
statestring[] | null
updated_at_gtestring | null
updated_at_ltestring | null

list_task_instance_tries

Выводит список попыток экземпляров задач по DAG ID, DAG run ID и task ID.

Перечисляет попытки экземпляра задачи.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
limitinteger | null
offsetinteger | null
order_bystring | null
task_idstringобязательный

list_variables

Перечисли все переменные.

Перечисляет переменные.

Параметры

limitinteger | null
offsetinteger | null
order_bystring | null

patch_dag

Обновить DAG

Patch Dag

Параметры

dag_idstringобязательный
is_pausedboolean | null
tagsstring[] | null

patch_dags

Обновить несколько DAGs

Патчит DAG.

Параметры

dag_id_patternstring | null
is_pausedboolean | null
tagsstring[] | null

patch_pool

Обновить пул

Пул патчей

Параметры

descriptionstring | null
The pool description.
include_deferredboolean | null
Whether to include deferred tasks in slot calculations.
pool_namestringобязательный
The pool name.
slotsinteger | null
The number of slots.

pause_dag

Приостановить DAG по ID

Pause Dag

Параметры

dag_idstringобязательный

post_dag_run

Запустить DAG по ID

Post Dag Run

Параметры

dag_idstringобязательный
dag_run_idstring | null
data_interval_endstring | null
data_interval_startstring | null
execution_datestring | null
logical_datestring | null
notestring | null

post_pool

Создать пул

Post Pool

Параметры

descriptionstring | null
The pool description.
include_deferredboolean | null
Whether to include deferred tasks in slot calculations.
namestringобязательный
The pool name.
slotsintegerобязательный
The number of slots.

reparse_dag_file

Запросить повторный разбор файла DAG

Переразбирает Dag File.

Параметры

file_tokenstringобязательный

set_dag_run_note

Обновить заметку DagRun

Устанавливает заметку для Dag Run.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
notestringобязательный

set_task_instances_state

Установить состояние экземпляров задач

Устанавливает состояние экземпляров задач.

Параметры

dag_idstringобязательный
dry_runboolean | null
execution_datestring | null
include_downstreamboolean | null
include_futureboolean | null
include_pastboolean | null
include_upstreamboolean | null
statestringобязательный
task_idsstring[] | null

test_connection

Проверить подключение

Проверяет соединение.

Параметры

conn_typestringобязательный
extrastring | null
hoststring | null
loginstring | null
passwordstring | null
portinteger | null
schemastring | null

unpause_dag

Возобновить DAG по ID

Снимает паузу с Dag.

Параметры

dag_idstringобязательный

update_connection

Обновить соединение по ID

Обновляет соединение.

Параметры

conn_idstringобязательный
conn_typestring | null
extrastring | null
hoststring | null
loginstring | null
passwordstring | null
portinteger | null
schemastring | null

update_dag_run_state

Обновить состояние выполнения DAG по ID DAG и ID запуска DAG

Обновляет состояние запуска DAG.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
statestring | null

update_task_instance

Обновить экземпляр задачи по DAG ID, DAG run ID и task ID.

Обновляет экземпляр задачи.

Параметры

dag_idstringобязательный
dag_run_idstringобязательный
statestring | null
task_idstringобязательный

update_variable

Обновить переменную по ключу

Обновляет переменную.

Параметры

descriptionstring | null
keystringобязательный
valuestring | null

Github Сайт сервера

Конфиг для установки сервера

{
  "command": "uvx",
  "args": [
    "mcp-server-apache-airflow"
  ],
  "env": {
    "AIRFLOW_HOST": "https://your-airflow-host",
    "AIRFLOW_USERNAME": "your-username",
    "AIRFLOW_PASSWORD": "your-password"
  }
}

Нужен uvx

Сервер запускается через uvx
Без него ничего работать не будет.

Как установить uvx

FAQ

Для чего этот сервер?

Этот сервер связывает MCP-клиенты с Apache Airflow. Он берёт на себя всю работу с REST API Airflow, чтобы AI-агенты и ассистенты могли управлять дагами, запускать их, смотреть логи, менять переменные и статусы задач. Вместо ручной интеграции достаточно подключить сервер — и MCP-клиент сам выполняет повседневные операции с пайплайнами.

Что он умеет?

Управляет DAG'ами: читает, создаёт, обновляет, ставит на паузу, запускает и удаляет их, перечитывает исходники. Запускает DAG-раны, меняет их статусы, очищает и удаляет. Работает с тасками и их инстансами: смотрит логи, попытки, обновляет состояния. Ведёт переменные, подключения и пулы: создаёт, читает, меняет и удаляет. Работает с датасетами и их событиями, XCom, конфигурацией, проверяет здоровье и версию Airflow.

Информация о сервере

Номер в рейтинге: #171
Звезд на Github: 178
Форков на Github: 49
Загрузок: 24 867
Язык реализации: Python
Лицензия: MIT
Официальный сервер: Нет
Дата обновления данных: 10.09 в 21:50
Идентификатор: -ZaJOf9JxOjndmoe
Категории: CI/CD и DevOps, Автоматизация приложений, Инструменты для разработчиков, Платформы данных