🐛 定时任务

2025-11-06 16:31:17 +08:00
parent 6390831f16
commit f71ee4fab4
1 changed files with 1 additions and 1 deletions
@@ -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)),