From 82b4e29d78742ce5af14dc8a3b34a8cb9cf7e6b1 Mon Sep 17 00:00:00 2001 From: Jeff Mitchell Date: Sat, 11 Jun 2022 11:04:40 -0500 Subject: [PATCH] Properly fix (for now) the job limit --- internal/daemon/controller/controller.go | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/internal/daemon/controller/controller.go b/internal/daemon/controller/controller.go index 2dff707033..9eac51878c 100644 --- a/internal/daemon/controller/controller.go +++ b/internal/daemon/controller/controller.go @@ -251,7 +251,7 @@ func New(ctx context.Context, conf *Config) (*Controller, error) { } // TODO: the RunJobsLimit is temporary until a better fix gets in. This // currently caps the scheduler at running 10 jobs per interval. - schedulerOpts := []scheduler.Option{scheduler.WithRunJobsLimit(10)} + schedulerOpts := []scheduler.Option{scheduler.WithRunJobsLimit(20)} if c.conf.RawConfig.Controller.SchedulerRunJobInterval > 0 { schedulerOpts = append(schedulerOpts, scheduler.WithRunJobsInterval(c.conf.RawConfig.Controller.SchedulerRunJobInterval)) } @@ -361,12 +361,9 @@ func (c *Controller) registerJobs() error { if err := pluginhost.RegisterJobs(c.baseContext, c.scheduler, rw, rw, c.kms, c.conf.HostPlugins); err != nil { return err } - // FIXME: This needs to get fixed before merge - /* - if err := session.RegisterJobs(c.baseContext, c.scheduler, rw, rw, c.kms, c.conf.StatusGracePeriodDuration); err != nil { - return err - } - */ + if err := session.RegisterJobs(c.baseContext, c.scheduler, rw, rw, c.kms, c.conf.StatusGracePeriodDuration); err != nil { + return err + } if err := serversjob.RegisterJobs(c.baseContext, c.scheduler, rw, rw, c.kms); err != nil { return err }