Skip to content

Commit 9e3b063

Browse files
committed
Add singleton mode
1 parent 873a118 commit 9e3b063

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

migrations/post_sync_migrations/migration_helpers.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,11 @@ func StartAsyncJobs(db *bun.DB) error {
142142
}
143143

144144
for _, job := range asyncJobs {
145-
if _, err = AsyncJobScheduler.NewJob(job.Schedule, job.Task); err != nil {
145+
if _, err = AsyncJobScheduler.NewJob(
146+
job.Schedule,
147+
job.Task,
148+
gocron.WithSingletonMode(gocron.LimitModeReschedule),
149+
); err != nil {
146150
return fmt.Errorf("error scheduling async job %s: %v", job.Name, err)
147151
}
148152
}

0 commit comments

Comments
 (0)