diff --git a/scheduler.go b/scheduler.go index 3676627..34cce9d 100644 --- a/scheduler.go +++ b/scheduler.go @@ -297,6 +297,7 @@ func (s *scheduler) selectRunJobRequest(run runJobRequest) { case run.outChan <- ErrJobNotFound: default: } + return } select { case <-s.shutdownCtx.Done():