This is an automated email from the ASF dual-hosted git repository.
jedcunningham 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 3749dbde2f Fix DB utils for Airflow Backwards compatability tests -
import not existing (#42522)
3749dbde2f is described below
commit 3749dbde2f87638033a43dfdcd22664a2e20f8b6
Author: Jens Scheffler <[email protected]>
AuthorDate: Thu Sep 26 23:44:20 2024 +0200
Fix DB utils for Airflow Backwards compatability tests - import not
existing (#42522)
---
tests/test_utils/db.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/tests/test_utils/db.py b/tests/test_utils/db.py
index 77875bb03e..bd56ed9175 100644
--- a/tests/test_utils/db.py
+++ b/tests/test_utils/db.py
@@ -35,7 +35,6 @@ from airflow.models import (
Variable,
XCom,
)
-from airflow.models.backfill import Backfill, BackfillDagRun
from airflow.models.dag import DagOwnerAttributes
from airflow.models.dagcode import DagCode
from airflow.models.dagwarning import DagWarning
@@ -68,6 +67,8 @@ def clear_db_runs():
def clear_db_backfills():
+ from airflow.models.backfill import Backfill, BackfillDagRun
+
with create_session() as session:
session.query(BackfillDagRun).delete()
session.query(Backfill).delete()
