Apache Airflow Certified

Triggers a DAG run for a specified dag_id

View Source

Last Updated: May. 7, 2021

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_idstrthe dag_id to trigger (templated)
confdictConfiguration for the DAG run
execution_datestr or datetime.datetimeExecution date for the dag (templated)
reset_dag_runboolWhether or not clear existing dag run if already exists. This is useful when backfill or rerun 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_completionboolWhether or not wait for dag run completion. (default: False)
poke_intervalintPoke interval to check dag run status when wait_for_completion=True. (default: 60)
allowed_stateslistlist of allowed states, default is ['success']
failed_stateslistlist of failed or dis-allowed states, default is None


Triggers a DAG run for a specified dag_id

Was this page helpful?