Run KubernetesPodOperator tests on any executor (#19810)

Previously these tests were restricted to run only on KubernetesExecutor. But there is no reason we cannot run them on other executors.
apache · Nov 29, 2021 · 68f13f0 · 68f13f0
1 parent e4c849e
commit 68f13f0
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 4 deletions.
diff --git a/kubernetes_tests/test_kubernetes_pod_operator.py b/kubernetes_tests/test_kubernetes_pod_operator.py
@@ -40,7 +40,6 @@
 from airflow.providers.cncf.kubernetes.utils.xcom_sidecar import PodDefaults
 from airflow.utils import timezone
 from airflow.version import version as airflow_version
-from kubernetes_tests.test_base import EXECUTOR
 
 
 def create_context(task):
@@ -65,7 +64,6 @@ def get_kubeconfig_path():
     return kubeconfig_path if kubeconfig_path else os.path.expanduser('~/.kube/config')
 
 
-@pytest.mark.skipif(EXECUTOR != 'KubernetesExecutor', reason="Only runs on KubernetesExecutor")
 class TestKubernetesPodOperatorSystem(unittest.TestCase):
     def get_current_task_name(self):
         # reverse test name to make pod name unique (it has limited length)

diff --git a/kubernetes_tests/test_kubernetes_pod_operator_backcompat.py b/kubernetes_tests/test_kubernetes_pod_operator_backcompat.py
@@ -41,7 +41,6 @@
 from airflow.utils import timezone
 from airflow.utils.state import State
 from airflow.version import version as airflow_version
-from kubernetes_tests.test_base import EXECUTOR
 
 # noinspection DuplicatedCode
 
@@ -64,7 +63,6 @@ def create_context(task):
 
 
 # noinspection DuplicatedCode,PyUnusedLocal
-@pytest.mark.skipif(EXECUTOR != 'KubernetesExecutor', reason="Only runs on KubernetesExecutor")
 class TestKubernetesPodOperatorSystem(unittest.TestCase):
     def get_current_task_name(self):
         # reverse test name to make pod name unique (it has limited length)