fix for some AWs that do not complete

project-codeflare · Oct 10, 2023 · 09735b4 · 09735b4
1 parent 1257d4b
commit 09735b4
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/controller/queuejob/queuejob_controller_ex.go b/pkg/controller/queuejob/queuejob_controller_ex.go
@@ -1625,7 +1625,10 @@ func (cc *XController) addQueueJob(obj interface{}) {
 					}
 					if latestAw.Status.State != arbv1.AppWrapperStateActive && latestAw.Status.State != arbv1.AppWrapperStateEnqueued && latestAw.Status.State != arbv1.AppWrapperStateRunningHoldCompletion {
 						klog.V(2).Infof("[Informer-addQJ] Stopping requeue for AW %s/%s with status %s", latestAw.Namespace, latestAw.Name, latestAw.Status.State)
-						break // Exit the loop
+						AwinEtcd, err := cc.arbclients.WorkloadV1beta1().AppWrappers(latestAw.Namespace).Get(context.Background(), latestAw.Name, metav1.GetOptions{})
+						if AwinEtcd.Status.State == latestAw.Status.State && err != nil {
+							break // Exit the loop
+						}
 					}
 					// Enqueue the latest copy of the AW.
 					if (qj.Status.State != arbv1.AppWrapperStateCompleted && qj.Status.State != arbv1.AppWrapperStateFailed) && hasCompletionStatus {