diff --git a/internal/framework/schedule/scanner.go b/internal/framework/schedule/scanner.go index a6f9cb0..d88baf2 100644 --- a/internal/framework/schedule/scanner.go +++ b/internal/framework/schedule/scanner.go @@ -117,7 +117,7 @@ func (ts *TaskScanner) scanCpdailyTask() { e = utils.Catch(func() { queue.AddTask(ts.ctx, asynq.NewTask(cst.TaskCpdaily, payloadWriter.Bytes()), asynq.TaskID(fmt.Sprintf("cpdaily:task:%d", task.ID)), - asynq.MaxRetry(1), + asynq.MaxRetry(3), asynq.Unique(10*time.Minute), asynq.ProcessAt(execTime), asynq.Deadline(execTime.Add(12*time.Minute)),