Skip to content

Commit 4d0da32

Browse files
committed
Revert "add preemptable candidates"
This reverts commit da08c4a.
1 parent da08c4a commit 4d0da32

File tree

1 file changed

+3
-9
lines changed

1 file changed

+3
-9
lines changed

pkg/controller/queuejob/queuejob_controller_ex.go

Lines changed: 3 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -954,7 +954,9 @@ func (qjm *XController) getAggregatedAvailableResourcesPriority(unallocatedClust
954954
continue
955955
}
956956

957-
addPreemptableAWs(preemptableAWs, value, queueJobKey, preemptableAWsMap)
957+
preemptableAWs[value.Status.SystemPriority] = append(preemptableAWs[value.Status.SystemPriority], queueJobKey)
958+
preemptableAWsMap[queueJobKey] = value
959+
klog.V(10).Infof("[getAggAvaiResPri] %s: Added %s to candidate preemptable job with priority %f.", time.Now().String(), value.Name, value.Status.SystemPriority)
958960
}
959961

960962
err := qjm.qjobResControls[arbv1.ResourceTypePod].UpdateQueueJobStatus(value)
@@ -966,8 +968,6 @@ func (qjm *XController) getAggregatedAvailableResourcesPriority(unallocatedClust
966968
klog.V(10).Infof("[getAggAvaiResPri] total resources consumed by Appwrapper %v when lower priority compared to target are %v", value.Name, totalResource)
967969
preemptable = preemptable.Add(totalResource)
968970
klog.V(6).Infof("[getAggAvaiResPri] %s proirity %v is lower target priority %v reclaiming total preemptable resources %v", value.Name, value.Status.SystemPriority, targetpr, totalResource)
969-
queueJobKey, _ := GetQueueJobKey(value)
970-
addPreemptableAWs(preemptableAWs, value, queueJobKey, preemptableAWsMap)
971971
continue
972972
} else if qjm.isDispatcher {
973973
// Dispatcher job does not currently track pod states. This is
@@ -1016,12 +1016,6 @@ func (qjm *XController) getAggregatedAvailableResourcesPriority(unallocatedClust
10161016
return r, proposedPremptions
10171017
}
10181018

1019-
func addPreemptableAWs(preemptableAWs map[float64][]string, value *arbv1.AppWrapper, queueJobKey string, preemptableAWsMap map[string]*arbv1.AppWrapper) {
1020-
preemptableAWs[value.Status.SystemPriority] = append(preemptableAWs[value.Status.SystemPriority], queueJobKey)
1021-
preemptableAWsMap[queueJobKey] = value
1022-
klog.V(10).Infof("[getAggAvaiResPri] %s: Added %s to candidate preemptable job with priority %f.", time.Now().String(), value.Name, value.Status.SystemPriority)
1023-
}
1024-
10251019
func (qjm *XController) chooseAgent(qj *arbv1.AppWrapper) string {
10261020

10271021
qjAggrResources := qjm.GetAggregatedResources(qj)

0 commit comments

Comments
 (0)