Skip to content

Commit 12109c0

Browse files
committed
merge
1 parent 5e2dd28 commit 12109c0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

pkg/controller/queuejob/queuejob_controller_ex.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1706,7 +1706,7 @@ func (cc *XController) updateQueueJob(oldObj, newObj interface{}) {
17061706
latestAw, exists, err := cc.appwrapperInformer.Informer().GetStore().GetByKey(key)
17071707
if latestAw.(*arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateCompleted || latestAw.(arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateFailed || latestAw.(arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateDeleted || !exists {
17081708
klog.V(2).Infof("[Informer-updateQJ] Stopping requeue for AW %s with status %s", latestAw.(*arbv1.AppWrapper).Name, latestAw.(*arbv1.AppWrapper).Status.State)
1709-
break
1709+
break //Exit the loop
17101710
}
17111711
if err == nil && exists {
17121712
// Enqueue the latest copy of the AW.

0 commit comments

Comments
 (0)