diff --git a/airflow/models/dagrun.py b/airflow/models/dagrun.py index e805eada21f40..3d50b05b5f2e9 100644 --- a/airflow/models/dagrun.py +++ b/airflow/models/dagrun.py @@ -124,7 +124,9 @@ class DagRun(Base, LoggingMixin): ), ) - task_instances = relationship(TI, back_populates="dag_run") + task_instances = relationship( + TI, back_populates="dag_run", cascade='save-update, merge, delete, delete-orphan' + ) DEFAULT_DAGRUNS_TO_EXAMINE = airflow_conf.getint( 'scheduler',