merge

asm582 · asm582 · commit 39315a535b25 · 2023-09-07T15:35:29.000-04:00
diff --git a/pkg/controller/queuejob/queuejob_controller_ex.go b/pkg/controller/queuejob/queuejob_controller_ex.go
@@ -1700,7 +1700,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.

Original file line number	Diff line number	Diff line change
`@@ -1700,7 +1700,7 @@ func (cc *XController) updateQueueJob(oldObj, newObj interface{}) {`
`1700`	`1700`	`latestAw, exists, err := cc.appwrapperInformer.Informer().GetStore().GetByKey(key)`
`1701`	`1701`	`if latestAw.(*arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateCompleted \|\| latestAw.(arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateFailed \|\| latestAw.(arbv1.AppWrapper).Status.State == arbv1.AppWrapperStateDeleted \|\| !exists {`
`1702`	`1702`	`klog.V(2).Infof("[Informer-updateQJ] Stopping requeue for AW %s with status %s", latestAw.(arbv1.AppWrapper).Name, latestAw.(arbv1.AppWrapper).Status.State)`
`1703`		`- break`
	`1703`	`+ break //Exit the loop`
`1704`	`1704`	`}`
`1705`	`1705`	`if err == nil && exists {`
`1706`	`1706`	`// Enqueue the latest copy of the AW.`