From 38deecc8291a0f2446eca19e9da713be538ce09f Mon Sep 17 00:00:00 2001 From: Moshe Immerman Date: Mon, 25 Dec 2023 00:29:56 +0200 Subject: [PATCH] fix: job scheduling error --- pkg/jobs/jobs.go | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/pkg/jobs/jobs.go b/pkg/jobs/jobs.go index 3590e34bc..c7669ce49 100644 --- a/pkg/jobs/jobs.go +++ b/pkg/jobs/jobs.go @@ -49,7 +49,8 @@ func Start() { logger.Fatalf("Failed to start upstream event queue consumer: %v", err) } - for _, job := range canaryJobs.UpstreamJobs { + for _, j := range canaryJobs.UpstreamJobs { + var job = j job.Context = context.DefaultContext if err := job.AddToScheduler(FuncScheduler); err != nil { logger.Errorf(err.Error()) @@ -57,7 +58,8 @@ func Start() { } } - for _, job := range db.CheckStatusJobs { + for _, j := range db.CheckStatusJobs { + var job = j job.Context = context.DefaultContext if err := job.AddToScheduler(FuncScheduler); err != nil { logger.Errorf(err.Error())