Skip to content

Commit

Permalink
[Issue-1084] Addjust scheduler extender algorithm
Browse files Browse the repository at this point in the history
Signed-off-by: Andrzej Zukowski <andrzej.zukowski@dell.com>
  • Loading branch information
Andrzej-Zukowski committed Feb 19, 2024
1 parent d5847f2 commit de99a52
Showing 1 changed file with 13 additions and 6 deletions.
19 changes: 13 additions & 6 deletions pkg/scheduler/extender/extender.go
Original file line number Diff line number Diff line change
Expand Up @@ -195,14 +195,21 @@ func (e *Extender) PrioritizeHandler(w http.ResponseWriter, req *http.Request) {
e.Lock()
defer e.Unlock()

hostPriority, err := e.score(extenderArgs.Nodes.Items)
if err != nil {
ll.Errorf("Unable to score %v", err)
return
pod := extenderArgs.Pod
var hostPriority []schedulerapi.HostPriority
requests, _ := e.gatherCapacityRequestsByProvisioner(context.TODO(), pod)
if len(requests) != 0 {
var err error
hostPriority, err = e.score(extenderArgs.Nodes.Items)
if err != nil {
ll.Errorf("Unable to score %v", err)
return
}
ll.Infof("Score results for pod %s: %v", pod, hostPriority)
} else {
ll.Infof("Skip skoring for pod: %s", pod)

Check warning on line 210 in pkg/scheduler/extender/extender.go

View check run for this annotation

Codecov / codecov/patch

pkg/scheduler/extender/extender.go#L198-L210

Added lines #L198 - L210 were not covered by tests
}
ll.Infof("Score results: %v", hostPriority)
extenderRes := (schedulerapi.HostPriorityList)(hostPriority)

if err := resp.Encode(&extenderRes); err != nil {
ll.Errorf("Unable to write response %v: %v", extenderRes, err)
}
Expand Down

0 comments on commit de99a52

Please sign in to comment.