Skip to content

Commit

Permalink
Fix DB utils for Airflow Backwards compatability tests - import not e…
Browse files Browse the repository at this point in the history
…xisting (apache#42522)
  • Loading branch information
jscheffl authored Sep 26, 2024
1 parent 84e8cdf commit 3749dbd
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion tests/test_utils/db.py
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,6 @@
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
Expand Down Expand Up @@ -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()
Expand Down

0 comments on commit 3749dbd

Please sign in to comment.