Skip to content

Commit 3ac5a83

Browse files
committed
revert code
1 parent a84b356 commit 3ac5a83

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

pkg/controller/queuejob/queuejob_controller_ex.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1250,7 +1250,6 @@ func (qjm *XController) ScheduleNext() {
12501250
resources, proposedPreemptions := qjm.getAggregatedAvailableResourcesPriority(
12511251
qjm.cache.GetUnallocatedResources(), priorityindex, qj, "")
12521252
klog.V(2).Infof("[ScheduleNext] XQJ %s with resources %v to be scheduled on aggregated idle resources %v", qj.Name, aggqj, resources)
1253-
var awWithoutQuota bool = false
12541253
if aggqj.LessEqual(resources) && qjm.nodeChecks(qjm.cache.GetUnallocatedHistograms(), qj) {
12551254
//Now evaluate quota
12561255
fits := true
@@ -1280,11 +1279,10 @@ func (qjm *XController) ScheduleNext() {
12801279
}
12811280
} else {
12821281
klog.V(10).Infof("[ScheduleNext] HOL quota evaluation not enabled for %s at %s activeQ=%t Unsched=%t &qj=%p Version=%s Status=%+v due to quota limits", qj.Name, time.Now().Sub(HOLStartTime), qjm.qjqueue.IfExistActiveQ(qj), qjm.qjqueue.IfExistUnschedulableQ(qj), qj, qj.ResourceVersion, qj.Status)
1283-
awWithoutQuota = true
12841282
}
12851283

12861284
// If quota evalauation is set or quota evaluation not enabled set the appwrapper to be dispatched
1287-
if fits || awWithoutQuota {
1285+
if fits {
12881286
// aw is ready to go!
12891287
apiQueueJob, e := qjm.queueJobLister.AppWrappers(qj.Namespace).Get(qj.Name)
12901288
// apiQueueJob's ControllerFirstTimestamp is only microsecond level instead of nanosecond level

0 commit comments

Comments
 (0)