Skip to content

Commit

Permalink
Fix confusing log message in kubernetes executor (apache#41035)
Browse files Browse the repository at this point in the history
* Fix confusing log message in kubernetes executor

* precommit
  • Loading branch information
RNHTTR authored Jul 31, 2024
1 parent 92c8697 commit 4ef847b
Showing 1 changed file with 6 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -472,7 +472,12 @@ def _change_state(
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)
Expand Down

0 comments on commit 4ef847b

Please sign in to comment.