(airflow) branch main updated: Update 'namespace' priority for 'find_pod' function (#43762)

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rom pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 66d86f51663 Update 'namespace' priority for 'find_pod' function (#43762)
66d86f51663 is described below

commit 66d86f51663718300917a5194eabd20ee67efdb5
Author: Maksim <ma...@google.com>
AuthorDate: Thu Nov 14 00:30:47 2024 -0800

    Update 'namespace' priority for 'find_pod' function (#43762)
---
 providers/src/airflow/providers/cncf/kubernetes/operators/pod.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/providers/src/airflow/providers/cncf/kubernetes/operators/pod.py b/providers/src/airflow/providers/cncf/kubernetes/operators/pod.py
index 2c99126230c..afb976f80f1 100644
--- a/providers/src/airflow/providers/cncf/kubernetes/operators/pod.py
+++ b/providers/src/airflow/providers/cncf/kubernetes/operators/pod.py
@@ -541,7 +541,7 @@ class KubernetesPodOperator(BaseOperator):
 
     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()))