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 <[email protected]>
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",
