diff --git a/pkg/scheduler/scheduler.go b/pkg/scheduler/scheduler.go index 5fd6f2d05c1..68ab65632b2 100644 --- a/pkg/scheduler/scheduler.go +++ b/pkg/scheduler/scheduler.go @@ -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)