From 12109c040bc79900db6ee1bfc33e34eeacd9f13f Mon Sep 17 00:00:00 2001 From: Abhishek Malvankar Date: Thu, 7 Sep 2023 15:35:29 -0400 Subject: [PATCH] merge --- pkg/controller/queuejob/queuejob_controller_ex.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/controller/queuejob/queuejob_controller_ex.go b/pkg/controller/queuejob/queuejob_controller_ex.go index 7d143d0a..24d0ac41 100644 --- a/pkg/controller/queuejob/queuejob_controller_ex.go +++ b/pkg/controller/queuejob/queuejob_controller_ex.go @@ -1706,7 +1706,7 @@ func (cc *XController) updateQueueJob(oldObj, newObj interface{}) { latestAw, exists, err := cc.appwrapperInformer.Informer().GetStore().GetByKey(key) if latestAw.(*arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateCompleted || latestAw.(arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateFailed || latestAw.(arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateDeleted || !exists { klog.V(2).Infof("[Informer-updateQJ] Stopping requeue for AW %s with status %s", latestAw.(*arbv1.AppWrapper).Name, latestAw.(*arbv1.AppWrapper).Status.State) - break + break //Exit the loop } if err == nil && exists { // Enqueue the latest copy of the AW.