MCPVault

trigger_dag

MCP tool from Astro Airflow MCP by astronomer

Trigger a new DAG run (start a workflow execution)

How to use it

trigger_dag is exposed by the Astro Airflow MCP MCP server. Add the server to your MCP client (Claude Desktop, Cursor, Windsurf and others), and the trigger_dag tool becomes available to the model automatically. See the full listing for setup details and every tool this server provides.

Install Astro Airflow MCP

$claude mcp add airflow -- uvx astro-airflow-mcp --transport stdio
FULL ASTRO AIRFLOW MCP LISTING

Other tools in Astro Airflow MCP (30)

daily_health_check

Morning health check routine

diagnose_dag_run

Debug a DAG run: run details, failed task instances, logs

explore_dag

Get comprehensive DAG info: metadata, tasks, recent runs, source code

get_airflow_config

Get Airflow configuration

get_airflow_version

Get Airflow version information

get_dag_details

Get detailed info about a specific DAG

get_dag_run

Get specific DAG run details

get_dag_source

Get the source code of a DAG

get_dag_stats

Get DAG run statistics (Airflow 3.x only)

get_pool

Get details about a specific pool

get_system_health

System overview: health status, import errors, warnings, DAG stats

get_task

Get details about a specific task

get_task_instance

Get task instance execution details

get_task_logs

Get logs for a specific task instance execution

get_variable

Get a specific variable by key

list_assets

Get assets/datasets (unified naming across versions)

list_connections

Get all connections (credentials excluded for security)

list_dag_runs

Get DAG run history

list_dag_warnings

Get DAG import warnings

list_dags

Get all DAGs and their metadata

list_import_errors

Get import errors from DAG files that failed to parse

list_plugins

Get installed Airflow plugins

list_pools

Get all resource pools

list_providers

Get installed provider packages

list_tasks

Get all tasks in a DAG

list_variables

Get all Airflow variables

onboard_new_dag

Guide for understanding a new DAG

pause_dag

Pause a DAG to prevent new scheduled runs

troubleshoot_failed_dag

Guided workflow for diagnosing DAG failures

unpause_dag

Unpause a DAG to resume scheduled runs