Update 'namespace' priority for 'find_pod' function (apache#43762)

aws-mwaa · Nov 14, 2024 · 66d86f5 · 66d86f5
1 parent e4426c3
commit 66d86f5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/providers/src/airflow/providers/cncf/kubernetes/operators/pod.py b/providers/src/airflow/providers/cncf/kubernetes/operators/pod.py
@@ -541,7 +541,7 @@ def log_matching_pod(self, pod: k8s.V1Pod, context: Context) -> None:
 
     def get_or_create_pod(self, pod_request_obj: k8s.V1Pod, context: Context) -> k8s.V1Pod:
         if self.reattach_on_restart:
-            pod = self.find_pod(self.namespace or pod_request_obj.metadata.namespace, context=context)
+            pod = self.find_pod(pod_request_obj.metadata.namespace, context=context)
             if pod:
                 return pod
         self.log.debug("Starting pod:\n%s", yaml.safe_dump(pod_request_obj.to_dict()))