This is an automated email from the ASF dual-hosted git repository.
rnhttr 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 4ef847b7d2 Fix confusing log message in kubernetes executor (#41035)
4ef847b7d2 is described below
commit 4ef847b7d23f9f5a62e02690972fcb5c6a3dcdac
Author: Ryan Hatter <[email protected]>
AuthorDate: Wed Jul 31 15:24:43 2024 -0400
Fix confusing log message in kubernetes executor (#41035)
* Fix confusing log message in kubernetes executor
* precommit
---
airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
index 612f64c8f3..754d835dc3 100644
--- a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
+++ b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor.py
@@ -472,7 +472,12 @@ class KubernetesExecutor(BaseExecutor):
if self.kube_config.delete_worker_pods:
if state != TaskInstanceState.FAILED or
self.kube_config.delete_worker_pods_on_failure:
self.kube_scheduler.delete_pod(pod_name=pod_name,
namespace=namespace)
- self.log.info("Deleted pod: %s in namespace %s", key,
namespace)
+ self.log.info(
+ "Deleted pod associated with the TI %s. Pod name: %s.
Namespace: %s",
+ key,
+ pod_name,
+ namespace,
+ )
else:
self.kube_scheduler.patch_pod_executor_done(pod_name=pod_name,
namespace=namespace)
self.log.info("Patched pod %s in namespace %s to mark it as done",
key, namespace)
