Run contact fire cron every 30 secs

nyaruka · Jan 28, 2025 · b9a149a · b9a149a
1 parent 42d20df
commit b9a149a
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/core/tasks/contacts/cron.go b/core/tasks/contacts/cron.go
@@ -26,7 +26,7 @@ func NewFiresCron(fetchBatchSize, taskBatchSize int) *FiresCron {
 }
 
 func (c *FiresCron) Next(last time.Time) time.Time {
-	return tasks.CronNext(last, time.Minute)
+	return tasks.CronNext(last, 30*time.Second)
 }
 
 func (c *FiresCron) AllInstances() bool {
@@ -128,8 +128,8 @@ func (c *FiresCron) Run(ctx context.Context, rt *runtime.Runtime) (map[string]an
 			}
 		}
 
-		// if we're getting close to a minute, stop and let the next cron run handle the rest
-		if time.Since(start) > 50*time.Second {
+		// if we're getting close to the repeat schedule of this task, stop and let the next run pick up the rest
+		if time.Since(start) > 25*time.Second {
 			break
 		}
 	}