Apache Airflow Certified

Triggers a DAG run for a specified dag_id

View on GitHub

Last Updated: Nov. 27, 2022

Access Instructions

Install the Apache Airflow provider package into your Airflow environment.

Import the module into your DAG file and instantiate it with your desired params.


trigger_dag_idRequiredThe dag_id to trigger (templated).
trigger_run_idThe run ID to use for the triggered DAG run (templated). If not provided, a run ID will be automatically generated.
confConfiguration for the DAG run (templated).
execution_dateExecution date for the dag (templated).
reset_dag_runWhether or not clear existing dag run if already exists. This is useful when backfill or rerun an existing dag run. This only resets (not recreates) the dag run. Dag run conf is immutable and will not be reset on rerun of an existing dag run. When reset_dag_run=False and dag run exists, DagRunAlreadyExists will be raised. When reset_dag_run=True and dag run exists, existing dag run will be cleared to rerun.
wait_for_completionWhether or not wait for dag run completion. (default: False)
poke_intervalPoke interval to check dag run status when wait_for_completion=True. (default: 60)
allowed_statesList of allowed states, default is ['success'].
failed_statesList of failed or dis-allowed states, default is None.
notesSet a custom note for the newly created DagRun.


Triggers a DAG run for a specified dag_id

Was this page helpful?