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 <[email protected]>
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()))
