fix: job scheduling error

flanksource · Dec 24, 2023 · 38deecc · 38deecc
1 parent 5065319
commit 38deecc
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/pkg/jobs/jobs.go b/pkg/jobs/jobs.go
@@ -49,15 +49,17 @@ 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())
 			}
 		}
 	}
 
-	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())