Skip to content

Commit a32c8c7

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

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
@@ -484,7 +484,9 @@ func (s *Scheduler) Bind(args extenderv1.ExtenderBindingArgs) (*extenderv1.Exten
484484
releaseNodeLocks := func() (*extenderv1.ExtenderBindingResult, error) {
485485
klog.InfoS("Release node locks", "node", args.Node)
486486
for _, val := range device.GetDevices() {
487-
val.ReleaseNodeLock(node, current)
487+
if releaseErr := val.ReleaseNodeLock(node, current); releaseErr != nil {
488+
klog.ErrorS(releaseErr, "Failed to release node lock", "node", args.Node, "device", val)
489+
}
488490
}
489491
s.recordScheduleBindingResultEvent(current, EventReasonBindingFailed, []string{}, err)
490492
return &extenderv1.ExtenderBindingResult{Error: err.Error()}, nil

0 commit comments

Comments
 (0)