From 87971c4d310fe3d353197fc96b9b6f9106f01e57 Mon Sep 17 00:00:00 2001 From: Valery Piashchynski Date: Mon, 12 Jul 2021 09:11:19 +0300 Subject: Typo in the pool configuration. Signed-off-by: Valery Piashchynski --- plugins/jobs/plugin.go | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/plugins/jobs/plugin.go b/plugins/jobs/plugin.go index 150c1d48..aab23f1c 100644 --- a/plugins/jobs/plugin.go +++ b/plugins/jobs/plugin.go @@ -279,14 +279,7 @@ func (p *Plugin) Reset() error { p.workersPool = nil var err error - p.workersPool, err = p.server.NewWorkerPool(context.Background(), &pool.Config{ - Debug: p.cfg.Pool.Debug, - NumWorkers: p.cfg.Pool.NumWorkers, - MaxJobs: p.cfg.Pool.MaxJobs, - AllocateTimeout: p.cfg.Pool.AllocateTimeout, - DestroyTimeout: p.cfg.Pool.DestroyTimeout, - Supervisor: p.cfg.Pool.Supervisor, - }, map[string]string{RrJobs: "true"}) + p.workersPool, err = p.server.NewWorkerPool(context.Background(), p.cfg.Pool, map[string]string{RrJobs: "true"}) if err != nil { return errors.E(op, err) } -- cgit v1.2.3