astro-airflow-mcp

Trigger a new DAG run (start a workflow execution manually).

Use this tool when the user asks to:

• "Run DAG X" or "Start DAG Y" or "Execute DAG Z"

• "Trigger a run of DAG X" or "Kick off DAG Y"

• "Run this workflow" or "Start this pipeline"

• "Execute DAG X with config Y" or "Trigger DAG with parameters"

• "Start a manual run" or "Manually execute this DAG"

This creates a new DAG run that will be picked up by the scheduler and executed. You can optionally pass configuration parameters that will be available to the DAG during execution via the conf context variable.

IMPORTANT: This is a write operation that modifies Airflow state by creating a new DAG run. Use with caution.

Returns information about the newly triggered DAG run including:

• dag_run_id: Unique identifier for the new execution

• dag_id: Which DAG was triggered

• state: Initial state (typically 'queued')

• execution_date: When this run is scheduled to execute

• start_date: When execution started (may be null if queued)

• run_type: Type of run (will be 'manual')

• conf: Configuration passed to the run

• external_trigger: Set to true for manual triggers

Args: dag_id: The ID of the DAG to trigger (e.g., "example_dag") conf: Optional configuration dictionary to pass to the DAG run. This will be available in the DAG via context['dag_run'].conf

Returns: JSON with details about the newly triggered DAG run