This is an automated email from the ASF dual-hosted git repository.
vincbeck pushed a commit to branch v3-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-3-test by this push:
new 7cccda2e26d [v3-3-test] Remove defensive bundle/team pre-cleaning from
api_fastapi tests (#69416) (#69420)
7cccda2e26d is described below
commit 7cccda2e26d0f86c45078d64b41b9d29a25acc7b
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Mon Jul 6 10:14:51 2026 -0400
[v3-3-test] Remove defensive bundle/team pre-cleaning from api_fastapi
tests (#69416) (#69420)
(cherry picked from commit 9ec996edc4f4dafc075cadf10752480941bc8799)
Co-authored-by: Anish Giri
<[email protected]>
---
airflow-core/tests/unit/api_fastapi/common/db/test_dags.py | 1 -
.../tests/unit/api_fastapi/core_api/routes/public/test_assets.py | 2 --
.../tests/unit/api_fastapi/core_api/routes/public/test_backfills.py | 1 +
.../tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py | 2 --
.../tests/unit/api_fastapi/core_api/routes/public/test_dag_stats.py | 4 ----
.../tests/unit/api_fastapi/core_api/routes/public/test_dag_tags.py | 2 --
.../unit/api_fastapi/core_api/routes/public/test_dag_versions.py | 3 +--
.../unit/api_fastapi/core_api/routes/public/test_import_error.py | 1 -
.../tests/unit/api_fastapi/core_api/routes/public/test_pools.py | 2 +-
.../unit/api_fastapi/core_api/routes/public/test_task_instances.py | 1 -
.../unit/api_fastapi/core_api/routes/public/test_task_state_store.py | 1 -
.../tests/unit/api_fastapi/core_api/routes/public/test_tasks.py | 1 -
.../tests/unit/api_fastapi/core_api/routes/public/test_variables.py | 1 -
.../tests/unit/api_fastapi/core_api/routes/ui/test_backfills.py | 1 -
14 files changed, 3 insertions(+), 20 deletions(-)
diff --git a/airflow-core/tests/unit/api_fastapi/common/db/test_dags.py
b/airflow-core/tests/unit/api_fastapi/common/db/test_dags.py
index a0747747670..1fe74438c84 100644
--- a/airflow-core/tests/unit/api_fastapi/common/db/test_dags.py
+++ b/airflow-core/tests/unit/api_fastapi/common/db/test_dags.py
@@ -45,7 +45,6 @@ class TestGenerateDagWithLatestRunQuery:
@pytest.fixture(autouse=True)
def setup_teardown(self):
"""Setup and teardown for each test."""
- self._clear_db()
yield
self._clear_db()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
index 0470b0b1e4e..3487fa28598 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_assets.py
@@ -253,7 +253,6 @@ class TestAssets:
clear_db_assets()
clear_db_runs()
clear_db_dags()
- clear_db_dag_bundles()
clear_db_logs()
yield
@@ -710,7 +709,6 @@ class TestAssetAliases:
clear_db_assets()
clear_db_runs()
clear_db_dags()
- clear_db_dag_bundles()
def teardown_method(self) -> None:
clear_db_assets()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_backfills.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_backfills.py
index 2380f73b9bf..d1bf2b51729 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_backfills.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_backfills.py
@@ -73,6 +73,7 @@ def _clean_db():
@pytest.fixture(autouse=True)
def clean_db():
+ yield
_clean_db()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
index 39a391f80f1..43a9e36c198 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_run.py
@@ -56,7 +56,6 @@ from tests_common.test_utils.asserts import
assert_queries_count
from tests_common.test_utils.db import (
clear_db_assets,
clear_db_connections,
- clear_db_dag_bundles,
clear_db_dags,
clear_db_logs,
clear_db_runs,
@@ -141,7 +140,6 @@ def setup(request, dag_maker, *, session=None):
clear_db_connections()
clear_db_runs()
clear_db_dags()
- clear_db_dag_bundles()
clear_db_serialized_dags()
clear_db_logs()
clear_db_assets()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_stats.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_stats.py
index a3f8038fe20..d807c363c42 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_stats.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_stats.py
@@ -134,10 +134,6 @@ class TestDagStatsEndpoint:
session.add_all(entities)
session.commit()
- @pytest.fixture(autouse=True)
- def setup(self) -> None:
- self._clear_db()
-
def teardown_method(self) -> None:
self._clear_db()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_tags.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_tags.py
index 82f3d11ed4f..2692ea07ff1 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_tags.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_tags.py
@@ -106,8 +106,6 @@ class TestDagEndpoint:
@pytest.fixture(autouse=True)
@provide_session
def setup(self, dag_maker, *, session=None) -> None:
- self._clear_db()
-
with dag_maker(
DAG1_ID,
dag_display_name=DAG1_DISPLAY_NAME,
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_versions.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_versions.py
index e83721783c7..73051be51df 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_versions.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_dag_versions.py
@@ -23,7 +23,7 @@ import pytest
from airflow.providers.standard.operators.empty import EmptyOperator
from tests_common.test_utils.asserts import assert_queries_count
-from tests_common.test_utils.db import clear_db_dag_bundles, clear_db_dags,
clear_db_serialized_dags
+from tests_common.test_utils.db import clear_db_dags, clear_db_serialized_dags
pytestmark = pytest.mark.db_test
@@ -33,7 +33,6 @@ class TestDagVersionEndpoint:
def setup(request, dag_maker, session):
clear_db_dags()
clear_db_serialized_dags()
- clear_db_dag_bundles()
with dag_maker(
dag_id="ANOTHER_DAG_ID", bundle_version="some_commit_hash",
bundle_name="another_bundle_name"
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
index 0db0c07c5f7..e7be4fa3219 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_import_error.py
@@ -102,7 +102,6 @@ def not_permitted_dag_model(testing_dag_bundle, *, session:
Session = NEW_SESSIO
def clear_db():
clear_db_import_errors()
clear_db_dags()
- clear_db_dag_bundles()
yield
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_pools.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_pools.py
index d779359d9cc..d56aceecfa0 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_pools.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_pools.py
@@ -73,10 +73,10 @@ class TestPoolsEndpoint:
@pytest.fixture(autouse=True)
def setup(self) -> None:
clear_db_pools()
- clear_db_teams()
def teardown_method(self) -> None:
clear_db_pools()
+ clear_db_teams()
def create_pools(self):
_create_team()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
index 40337bb9be7..93569e59482 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_instances.py
@@ -6004,7 +6004,6 @@ class TestBulkTaskInstances(TestTaskInstanceEndpoint):
@pytest.fixture(autouse=True)
def clean_db(self, session):
clear_db_runs()
- clear_db_teams()
yield
clear_db_teams()
clear_db_runs()
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_state_store.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_state_store.py
index 40611064356..650858656da 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_state_store.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_task_state_store.py
@@ -78,7 +78,6 @@ class TestTaskStateEndpoint:
@pytest.fixture(autouse=True)
def setup(self, dag_maker, session):
- self.clear_db()
_create_dag_run(dag_maker, session)
self.dag_run = session.scalar(select(DagRun).where(DagRun.run_id ==
RUN_ID))
self._session = session
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_tasks.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_tasks.py
index 0dacd19397e..9fc48a9bbb8 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_tasks.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_tasks.py
@@ -81,7 +81,6 @@ class TestTaskEndpoint:
@pytest.fixture(autouse=True)
def setup(self, test_client) -> None:
- self.clear_db()
self.create_dags(test_client)
def teardown_method(self) -> None:
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_variables.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_variables.py
index ed480b03602..234bbe6b1f7 100644
---
a/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_variables.py
+++
b/airflow-core/tests/unit/api_fastapi/core_api/routes/public/test_variables.py
@@ -141,7 +141,6 @@ class TestVariableEndpoint:
@pytest.fixture(autouse=True)
def setup(self):
clear_db_variables()
- clear_db_teams()
with conf_vars({("core", "multi_team"): "True"}):
yield
diff --git
a/airflow-core/tests/unit/api_fastapi/core_api/routes/ui/test_backfills.py
b/airflow-core/tests/unit/api_fastapi/core_api/routes/ui/test_backfills.py
index 21ae10d23b3..ebb23efff7d 100644
--- a/airflow-core/tests/unit/api_fastapi/core_api/routes/ui/test_backfills.py
+++ b/airflow-core/tests/unit/api_fastapi/core_api/routes/ui/test_backfills.py
@@ -53,7 +53,6 @@ def _clean_db():
@pytest.fixture(autouse=True)
def clean_db():
- _clean_db()
yield
_clean_db()
