From b76944b185604634c9dac36acb9c984e77257bfa Mon Sep 17 00:00:00 2001 From: guanguxiansheng <1439425373@qq.com> Date: Sun, 14 Dec 2025 00:13:36 +0800 Subject: [PATCH] fix: remove pod finalizer in abnormal scenarios Signed-off-by: guanguxiansheng <1439425373@qq.com> --- workflow/controller/pod/controller.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/workflow/controller/pod/controller.go b/workflow/controller/pod/controller.go index 6e1556a56d28..f120e3dcd90c 100644 --- a/workflow/controller/pod/controller.go +++ b/workflow/controller/pod/controller.go @@ -242,7 +242,8 @@ func (c *Controller) addPodEvent(ctx context.Context, pod *apiv1.Pod) { if err != nil { c.log.WithField("pod", pod.Name).Warn(ctx, "callback for pod add failed") } - c.commonPodEvent(ctx, pod, false) + deleting := pod.DeletionTimestamp != nil + c.commonPodEvent(ctx, pod, deleting) } func (c *Controller) updatePodEvent(ctx context.Context, old *apiv1.Pod, newPod *apiv1.Pod) { @@ -252,7 +253,8 @@ func (c *Controller) updatePodEvent(ctx context.Context, old *apiv1.Pod, newPod if err != nil { c.log.WithField("pod", newPod.Name).Warn(ctx, "callback for pod update failed") } - c.commonPodEvent(ctx, newPod, false) + deleting := newPod.DeletionTimestamp != nil + c.commonPodEvent(ctx, newPod, deleting) } func (c *Controller) deletePodEvent(ctx context.Context, obj interface{}) {