add failed AWs to backoff

asm582 · openshift-merge-robot · commit 445c8f3300f8 · 2023-08-17T15:22:10.000-02:30
diff --git a/pkg/controller/queuejob/queuejob_controller_ex.go b/pkg/controller/queuejob/queuejob_controller_ex.go
@@ -1259,6 +1259,8 @@ func (qjm *XController) ScheduleNext(qj *arbv1.AppWrapper) {
 						qjm.qjqueue.IfExistUnschedulableQ(qj), qj, qj.ResourceVersion, qj.Status)
 					//TODO: Remove forwarded logic as a big AW will never be forwarded
 					forwarded = true
+					// should we call backoff or update etcd?
+					go qjm.backoff(ctx, qj, dispatchFailedReason, dispatchFailedMessage)
 				}
 				// if the HeadOfLineHoldingTime option is not set it will break the loop
 				//schedulingTimeExpired := time.Now().After(HOLStartTime.Add(time.Duration(qjm.serverOption.HeadOfLineHoldingTime) * time.Second))

Original file line number	Diff line number	Diff line change
`@@ -1259,6 +1259,8 @@ func (qjm XController) ScheduleNext(qj arbv1.AppWrapper) {`
`1259`	`1259`	`qjm.qjqueue.IfExistUnschedulableQ(qj), qj, qj.ResourceVersion, qj.Status)`
`1260`	`1260`	`//TODO: Remove forwarded logic as a big AW will never be forwarded`
`1261`	`1261`	`forwarded = true`
	`1262`	`+ // should we call backoff or update etcd?`
	`1263`	`+ go qjm.backoff(ctx, qj, dispatchFailedReason, dispatchFailedMessage)`
`1262`	`1264`	`}`
`1263`	`1265`	`// if the HeadOfLineHoldingTime option is not set it will break the loop`
`1264`	`1266`	`//schedulingTimeExpired := time.Now().After(HOLStartTime.Add(time.Duration(qjm.serverOption.HeadOfLineHoldingTime) * time.Second))`