diff --git a/pkg/scheduler/service.go b/pkg/scheduler/service.go index 9bf55d3cd..a4da9d639 100644 --- a/pkg/scheduler/service.go +++ b/pkg/scheduler/service.go @@ -140,16 +140,14 @@ func (svc *service) watch(ctx context.Context) { svc.dispatch(ctx) for { - func() { - select { - case <-svc.ticker().C: - svc.dispatch(ctx) + select { + case <-svc.ticker().C: + svc.dispatch(ctx) - case <-ctx.Done(): - svc.log.Debug("done") - return - } - }() + case <-ctx.Done(): + svc.log.Debug("done") + return + } } }