Skip to content

Commit

Permalink
Reverse cancellation.NewError one
Browse files Browse the repository at this point in the history
  • Loading branch information
alexweav committed Aug 23, 2024
1 parent 7438520 commit 35c113b
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/scheduler/scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -405,7 +405,7 @@ func (s *Scheduler) cancelRequestAndRemoveFromPending(key queue.RequestKey, reas

req := s.schedulerInflightRequests[key]
if req != nil {
req.CancelFunc(cancellation.NewError(reason))
req.CancelFunc(cancellation.NewErrorf("%s", reason))
}

delete(s.schedulerInflightRequests, key)
Expand Down

0 comments on commit 35c113b

Please sign in to comment.