Airflow Summit 2025 is coming October 07-09. Register now for early bird ticket!

TriggerDagRunOperator

Use the TriggerDagRunOperator to trigger dag from another dag.

tests/system/standard/example_trigger_controller_dag.py[source]


trigger = TriggerDagRunOperator(
    task_id="test_trigger_dagrun",
    trigger_dag_id="example_trigger_target_dag",  # Ensure this equals the dag_id of the DAG to trigger
    conf={"message": "Hello World"},
)

Was this entry helpful?