fix: cron scheduler duplicating logic

Signed-off-by: Alexander Trost <[email protected]>
fivenet-app · Oct 28, 2024 · 7168288 · 7168288
1 parent 0b2e747
commit 7168288
Showing 1 changed file with 14 additions and 7 deletions.
diff --git a/pkg/croner/scheduler.go b/pkg/croner/scheduler.go
@@ -74,13 +74,20 @@ func NewScheduler(p SchedulerParams) (*Scheduler, error) {
 					return cj, nil
 				}
 
-				ctx, cancel := context.WithCancel(ctxCancel)
-				s.jobs.Store(cj.Name, &jobWrapper{
-					ctx:    ctx,
-					cancel: cancel,
-
-					schedule: cj.Schedule,
-				})
+				jw, ok := s.jobs.Load(cj.Name)
+				if !ok {
+					ctx, cancel := context.WithCancel(ctxCancel)
+					s.jobs.Store(cj.Name, &jobWrapper{
+						ctx:    ctx,
+						cancel: cancel,
+
+						schedule: cj.Schedule,
+					})
+				} else {
+					if cj.Schedule != jw.schedule {
+						jw.schedule = cj.Schedule
+					}
+				}
 
 				return cj, nil
 			}),