Skip to content

Commit b8d988d

Browse files
committed
fix(scheduler): handle error when releasing node locks
Signed-off-by: yxxhero <[email protected]>
1 parent 9fc9f44 commit b8d988d

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

pkg/scheduler/scheduler.go

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,9 @@ func (s *Scheduler) Bind(args extenderv1.ExtenderBindingArgs) (*extenderv1.Exten
460460
releaseNodeLocks := func() (*extenderv1.ExtenderBindingResult, error) {
461461
klog.InfoS("Release node locks", "node", args.Node)
462462
for _, val := range device.GetDevices() {
463-
val.ReleaseNodeLock(node, current)
463+
if releaseErr := val.ReleaseNodeLock(node, current); releaseErr != nil {
464+
klog.ErrorS(releaseErr, "Failed to release node lock", "node", args.Node, "device", val)
465+
}
464466
}
465467
s.recordScheduleBindingResultEvent(current, EventReasonBindingFailed, []string{}, err)
466468
return &extenderv1.ExtenderBindingResult{Error: err.Error()}, nil

0 commit comments

Comments
 (0)