Don't overwrite pod in kube_pod_executor reconcile() if it is already…

… set
Yelp · Jun 14, 2024 · 3860848 · 3860848
1 parent ad5f77c
commit 3860848
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/task_processing/plugins/kubernetes/kubernetes_pod_executor.py b/task_processing/plugins/kubernetes/kubernetes_pod_executor.py
@@ -608,8 +608,10 @@ def reconcile(self, task_config: KubernetesTaskConfig) -> None:
             try:
                 pod = kube_client.get_pod(namespace=self.namespace, pod_name=pod_name)
             except Exception:
-                logger.exception(f"Hit an exception attempting to fetch pod {pod_name}")
-                pod = None
+                logger.exception(
+                    f"Hit an exception attempting to fetch pod {pod_name} from {kube_client.kubeconfig_path}"
+                )
+                pod = None if not pod else pod
             else:
                 break