This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch v3-1-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-1-test by this push:
new 55951050beb [v3-1-test] fix flaky TestEmrCreateJobFlowOperator
(#59128) (#59137)
55951050beb is described below
commit 55951050beb47508f45792fc216b35a078938af8
Author: Jason(Zhe-You) Liu <[email protected]>
AuthorDate: Mon Dec 8 06:23:11 2025 +0800
[v3-1-test] fix flaky TestEmrCreateJobFlowOperator (#59128) (#59137)
(cherry picked from commit 97cf3c7)
Co-authored-by: Henry Chen <[email protected]>
---
devel-common/src/tests_common/test_utils/db.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/devel-common/src/tests_common/test_utils/db.py
b/devel-common/src/tests_common/test_utils/db.py
index 63b9d93d3b0..3741b788cf6 100644
--- a/devel-common/src/tests_common/test_utils/db.py
+++ b/devel-common/src/tests_common/test_utils/db.py
@@ -252,9 +252,9 @@ def clear_db_dags():
session.query(DagFavorite).delete()
session.query(DagTag).delete()
session.query(DagOwnerAttributes).delete()
- session.query(
- DagRun
- ).delete() # todo: this should not be necessary because the fk to
DagVersion should be ON DELETE SET NULL
+ session.query(DagRun).delete(
+ synchronize_session=False
+ ) # todo: this should not be necessary because the fk to DagVersion
should be ON DELETE SET NULL
session.query(DagModel).delete()
