@@ -157,7 +157,6 @@ def test_execution_date_serialize_deserialize(self):
157
157
158
158
assert datetime_obj == new_datetime_obj
159
159
160
- @pytest .mark .db_test
161
160
@pytest .mark .skipif (
162
161
AirflowKubernetesScheduler is None , reason = "kubernetes python package is not installed"
163
162
)
@@ -180,7 +179,6 @@ def test_delete_pod_successfully(self, mock_watcher, mock_client, mock_kube_clie
180
179
finally :
181
180
kube_executor .end ()
182
181
183
- @pytest .mark .db_test
184
182
@pytest .mark .skipif (
185
183
AirflowKubernetesScheduler is None , reason = "kubernetes python package is not installed"
186
184
)
@@ -204,7 +202,6 @@ def test_delete_pod_raises_404(self, mock_watcher, mock_client, mock_kube_client
204
202
kube_executor .kube_scheduler .delete_pod (pod_name , namespace )
205
203
mock_delete_namespace .assert_called_with (pod_name , namespace , body = mock_client .V1DeleteOptions ())
206
204
207
- @pytest .mark .db_test
208
205
@pytest .mark .skipif (
209
206
AirflowKubernetesScheduler is None , reason = "kubernetes python package is not installed"
210
207
)
@@ -253,7 +250,6 @@ def setup_method(self) -> None:
253
250
self .kubernetes_executor = KubernetesExecutor ()
254
251
self .kubernetes_executor .job_id = 5
255
252
256
- @pytest .mark .db_test
257
253
@pytest .mark .skipif (
258
254
AirflowKubernetesScheduler is None , reason = "kubernetes python package is not installed"
259
255
)
@@ -455,7 +451,6 @@ def test_run_next_exception_requeue(
455
451
finally :
456
452
kubernetes_executor .end ()
457
453
458
- @pytest .mark .db_test
459
454
@pytest .mark .skipif (
460
455
AirflowKubernetesScheduler is None , reason = "kubernetes python package is not installed"
461
456
)
@@ -495,7 +490,6 @@ def test_run_next_pmh_error(self, mock_get_kube_client, mock_pmh):
495
490
finally :
496
491
kubernetes_executor .end ()
497
492
498
- @pytest .mark .db_test
499
493
@pytest .mark .skipif (
500
494
AirflowKubernetesScheduler is None , reason = "kubernetes python package is not installed"
501
495
)
@@ -561,7 +555,6 @@ def test_gauge_executor_metrics(self, mock_stats_gauge, mock_trigger_tasks, mock
561
555
]
562
556
mock_stats_gauge .assert_has_calls (calls )
563
557
564
- @pytest .mark .db_test
565
558
@mock .patch ("airflow.providers.cncf.kubernetes.executors.kubernetes_executor_utils.KubernetesJobWatcher" )
566
559
@mock .patch ("airflow.providers.cncf.kubernetes.kube_client.get_kube_client" )
567
560
def test_invalid_executor_config (self , mock_get_kube_client , mock_kubernetes_job_watcher ):
@@ -584,7 +577,6 @@ def test_invalid_executor_config(self, mock_get_kube_client, mock_kubernetes_job
584
577
finally :
585
578
executor .end ()
586
579
587
- @pytest .mark .db_test
588
580
@pytest .mark .execution_timeout (10 )
589
581
@pytest .mark .skipif (
590
582
AirflowKubernetesScheduler is None , reason = "kubernetes python package is not installed"
@@ -801,7 +793,6 @@ def test_change_state_key_not_in_running(self, mock_get_kube_client, mock_kubern
801
793
finally :
802
794
executor .end ()
803
795
804
- @pytest .mark .db_test
805
796
@pytest .mark .parametrize (
806
797
"multi_namespace_mode_namespace_list, watchers_keys" ,
807
798
[
0 commit comments