diff --git a/kubernetes_tests/test_kubernetes_pod_operator.py b/kubernetes_tests/test_kubernetes_pod_operator.py index d51a5e0633d01..3944dc7974db1 100644 --- 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 index 683400886d5fa..6cbfabd5e91ad 100644 --- 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)