File tree 1 file changed +2
-5
lines changed
pkg/scheduler/plugins/proportion
1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -218,16 +218,13 @@ func (pp *proportionPlugin) OnSessionOpen(ssn *framework.Session) {
218
218
queue := ssn .Queues [queueID ]
219
219
220
220
// If no capability is set, always enqueue the job.
221
- if len (queue .Queue .Spec .Capability ) == 0 {
222
- return true
223
- }
224
-
225
- pgResource := api .NewResource (* job .PodGroup .Spec .MinResources )
226
221
if len (queue .Queue .Spec .Capability ) == 0 {
227
222
klog .V (4 ).Infof ("Capability of queue <%s> was not set, allow job <%s/%s> to Inqueue." ,
228
223
queue .Name , job .Namespace , job .Name )
229
224
return true
230
225
}
226
+
227
+ pgResource := api .NewResource (* job .PodGroup .Spec .MinResources )
231
228
// The queue resource quota limit has not reached
232
229
if pgResource .Clone ().Add (attr .allocated ).LessEqual (api .NewResource (queue .Queue .Spec .Capability )) {
233
230
return true
You can’t perform that action at this time.
0 commit comments