From 185f5de87a7dfd8c68962b1f806dd0accac0587b Mon Sep 17 00:00:00 2001 From: Derrick Hammer Date: Thu, 1 Feb 2024 21:03:19 -0500 Subject: [PATCH] fix: ensure limit is greater than 0 --- cron/cron.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/cron/cron.go b/cron/cron.go index e8669c7..2ae7d65 100644 --- a/cron/cron.go +++ b/cron/cron.go @@ -117,7 +117,7 @@ func (c *CronServiceDefault) RetryableTask(params RetryableTaskParams) CronJob { listeners := gocron.WithEventListeners(gocron.AfterJobRunsWithError(func(jobID uuid.UUID, jobName string, err error) { params.Error(jobID, jobName, err) - if params.Attempt >= params.Limit { + if params.Attempt >= params.Limit && params.Limit > 0 { c.logger.Error("Retryable task limit reached", zap.String("jobName", jobName), zap.String("jobID", jobID.String())) params.Error(jobID, jobName, ErrRetryLimitReached) return