Skip to content

Commit 27326e4

Browse files
author
draveness
committed
feat(scheduler): scale the extender output in generic scheduler
1 parent 3b58b35 commit 27326e4

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

pkg/scheduler/apis/extender/v1/types.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,10 @@ import (
2323

2424
const (
2525
// MinExtenderPriority defines the min priority value for extender.
26-
MinExtenderPriority int = 0
26+
MinExtenderPriority int64 = 0
2727

2828
// MaxExtenderPriority defines the max priority value for extender.
29-
MaxExtenderPriority int = 10
29+
MaxExtenderPriority int64 = 10
3030
)
3131

3232
// ExtenderPreemptionResult represents the result returned by preemption phase of extender.

pkg/scheduler/core/generic_scheduler.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -840,7 +840,9 @@ func PrioritizeNodes(
840840
// wait for all go routines to finish
841841
wg.Wait()
842842
for i := range result {
843-
result[i].Score += combinedScores[result[i].Name]
843+
// MaxExtenderPriority may diverge from the max priority used in the scheduler and defined by MaxNodeScore,
844+
// therefore we need to scale the score returned by extenders to the score range used by the scheduler.
845+
result[i].Score += combinedScores[result[i].Name] * (framework.MaxNodeScore / extenderv1.MaxExtenderPriority)
844846
}
845847
}
846848

0 commit comments

Comments
 (0)