(airflow) branch main updated: Remove @pytest.mark.db_test for cncf (#52153)

[kaxilnaik]

This is an automated email from the ASF dual-hosted git repository.

kaxilnaik 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 1b63a052578 Remove @pytest.mark.db_test for cncf (#52153)
1b63a052578 is described below

commit 1b63a052578610284c9e21fcdfb6a54a99dfb3d1
Author: Ankit Chaurasia <8670962+sunank...@users.noreply.github.com>
AuthorDate: Wed Jun 25 00:10:12 2025 +0545

    Remove @pytest.mark.db_test for cncf (#52153)
---
 .../unit/cncf/kubernetes/executors/test_kubernetes_executor.py   | 9 ---------
 .../unit/cncf/kubernetes/operators/test_spark_kubernetes.py      | 2 --
 2 files changed, 11 deletions(-)

diff --git 
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
 
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
index 62616ea4bc3..062c889089e 100644
--- 
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
+++ 
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/executors/test_kubernetes_executor.py
@@ -157,7 +157,6 @@ class TestAirflowKubernetesScheduler:
 
         assert datetime_obj == new_datetime_obj
 
-    @pytest.mark.db_test
     @pytest.mark.skipif(
         AirflowKubernetesScheduler is None, reason="kubernetes python package 
is not installed"
     )
@@ -180,7 +179,6 @@ class TestAirflowKubernetesScheduler:
         finally:
             kube_executor.end()
 
-    @pytest.mark.db_test
     @pytest.mark.skipif(
         AirflowKubernetesScheduler is None, reason="kubernetes python package 
is not installed"
     )
@@ -204,7 +202,6 @@ class TestAirflowKubernetesScheduler:
             kube_executor.kube_scheduler.delete_pod(pod_name, namespace)
         mock_delete_namespace.assert_called_with(pod_name, namespace, 
body=mock_client.V1DeleteOptions())
 
-    @pytest.mark.db_test
     @pytest.mark.skipif(
         AirflowKubernetesScheduler is None, reason="kubernetes python package 
is not installed"
     )
@@ -253,7 +250,6 @@ class TestKubernetesExecutor:
         self.kubernetes_executor = KubernetesExecutor()
         self.kubernetes_executor.job_id = 5
 
-    @pytest.mark.db_test
     @pytest.mark.skipif(
         AirflowKubernetesScheduler is None, reason="kubernetes python package 
is not installed"
     )
@@ -455,7 +451,6 @@ class TestKubernetesExecutor:
             finally:
                 kubernetes_executor.end()
 
-    @pytest.mark.db_test
     @pytest.mark.skipif(
         AirflowKubernetesScheduler is None, reason="kubernetes python package 
is not installed"
     )
@@ -495,7 +490,6 @@ class TestKubernetesExecutor:
         finally:
             kubernetes_executor.end()
 
-    @pytest.mark.db_test
     @pytest.mark.skipif(
         AirflowKubernetesScheduler is None, reason="kubernetes python package 
is not installed"
     )
@@ -561,7 +555,6 @@ class TestKubernetesExecutor:
         ]
         mock_stats_gauge.assert_has_calls(calls)
 
-    @pytest.mark.db_test
     
@mock.patch("airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher")
     
@mock.patch("airflow.providers.cncf.kubernetes.kube_client.get_kube_client")
     def test_invalid_executor_config(self, mock_get_kube_client, 
mock_kubernetes_job_watcher):
@@ -584,7 +577,6 @@ class TestKubernetesExecutor:
         finally:
             executor.end()
 
-    @pytest.mark.db_test
     @pytest.mark.execution_timeout(10)
     @pytest.mark.skipif(
         AirflowKubernetesScheduler is None, reason="kubernetes python package 
is not installed"
@@ -801,7 +793,6 @@ class TestKubernetesExecutor:
         finally:
             executor.end()
 
-    @pytest.mark.db_test
     @pytest.mark.parametrize(
         "multi_namespace_mode_namespace_list, watchers_keys",
         [
diff --git 
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_spark_kubernetes.py
 
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_spark_kubernetes.py
index ff30d9ac797..2b9c7997e7e 100644
--- 
a/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_spark_kubernetes.py
+++ 
b/providers/cncf/kubernetes/tests/unit/cncf/kubernetes/operators/test_spark_kubernetes.py
@@ -222,7 +222,6 @@ def create_context(task):
     }
 
 
-@pytest.mark.db_test
 
@patch("airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager.fetch_requested_container_logs")
 
@patch("airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager.await_pod_completion")
 
@patch("airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager.create_pod")
@@ -473,7 +472,6 @@ class TestSparkKubernetesOperatorCreateApplication:
         )
 
 
-@pytest.mark.db_test
 
@patch("airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager.fetch_requested_container_logs")
 
@patch("airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager.await_pod_completion")
 
@patch("airflow.providers.cncf.kubernetes.utils.pod_manager.PodManager.create_pod")