This is an automated email from the ASF dual-hosted git repository. taragolis pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push: new 575c11e02d Configure `back_populates` between `DagScheduleDatasetReference.dag` and `DagModel.schedule_dataset_references` (#39392) 575c11e02d is described below commit 575c11e02d4821409a25acba215211c29e7b92ab Author: Andrey Anshin <andrey.ans...@taragol.is> AuthorDate: Sun May 5 02:42:00 2024 +0400 Configure `back_populates` between `DagScheduleDatasetReference.dag` and `DagModel.schedule_dataset_references` (#39392) --- airflow/models/dag.py | 1 + airflow/models/dataset.py | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/airflow/models/dag.py b/airflow/models/dag.py index 111757b016..9db0de45a0 100644 --- a/airflow/models/dag.py +++ b/airflow/models/dag.py @@ -3668,6 +3668,7 @@ class DagModel(Base): ) schedule_dataset_references = relationship( "DagScheduleDatasetReference", + back_populates="dag", cascade="all, delete, delete-orphan", ) schedule_datasets = association_proxy("schedule_dataset_references", "dataset") diff --git a/airflow/models/dataset.py b/airflow/models/dataset.py index 19ebce0897..7b42ff324b 100644 --- a/airflow/models/dataset.py +++ b/airflow/models/dataset.py @@ -112,7 +112,7 @@ class DagScheduleDatasetReference(Base): updated_at = Column(UtcDateTime, default=timezone.utcnow, onupdate=timezone.utcnow, nullable=False) dataset = relationship("DatasetModel", back_populates="consuming_dags") - dag = relationship("DagModel") + dag = relationship("DagModel", back_populates="schedule_dataset_references") queue_records = relationship( "DatasetDagRunQueue",