Revert "Fix error with quick-failing tasks in KubernetesPodOperator (a…

…pache#13621)" (apache#13835) This reverts commit 94d3ed6. Co-authored-by: Daniel Imberman <[email protected]>
DeepHiveMind · Jan 22, 2021 · 1b9e3d1 · 1b9e3d1
1 parent df1503e
commit 1b9e3d1
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 26 deletions.
diff --git a/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py b/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py
@@ -343,7 +343,6 @@ def execute(self, context) -> Optional[str]:
                 raise AirflowException(f'Pod {self.pod.metadata.name} returned a failure: {status}')
             return result
         except AirflowException as ex:
-            self.patch_already_checked(self.pod)
             raise AirflowException(f'Pod Launching failed: {ex}')
 
     def handle_pod_overlap(

diff --git a/kubernetes_tests/test_kubernetes_pod_operator.py b/kubernetes_tests/test_kubernetes_pod_operator.py
@@ -1000,30 +1000,5 @@ def test_reattach_failing_pod_once(self):
             k.execute(context)
             create_mock.assert_called_once()
 
-    def test_reatttach_quick_failure(self):
-        client = kube_client.get_kube_client(in_cluster=False)
-        namespace = "default"
-
-        name = "test"
-        k = KubernetesPodOperator(
-            namespace='default',
-            image="ubuntu:16.04",
-            cmds=["bash", "-cx"],
-            arguments=["exit 1"],
-            labels={"foo": "bar"},
-            name="test",
-            task_id=name,
-            in_cluster=False,
-            do_xcom_push=False,
-            is_delete_operator_pod=False,
-            termination_grace_period=0,
-        )
-
-        context = create_context(k)
-        with self.assertRaises(AirflowException):
-            k.execute(context)
-        pod = client.read_namespaced_pod(name=k.pod.metadata.name, namespace=namespace)
-        self.assertEqual(pod.metadata.labels["already_checked"], "True")
-
 
 # pylint: enable=unused-argument