diff --git a/internal/service/email/email_service.go b/internal/service/email/email_service.go index 42cdeec..8ce9265 100644 --- a/internal/service/email/email_service.go +++ b/internal/service/email/email_service.go @@ -143,7 +143,7 @@ func (s *EmailServiceV1) sendEmail(ctx context.Context, to, subject, body string utils.OkOrPanic(e, oops.WithContext(ctx).Wrap) task := queue.AddTask(ctx, asynq.NewTask(cst2.TaskEmail, payload.Bytes()), asynq.Queue(cst2.TaskQueueEmail), - asynq.MaxRetry(3), + asynq.MaxRetry(1), asynq.Timeout(5*time.Minute), ) logger.Logger.Info("添加任务: ", zap.String("task_id", task.ID), zap.String("邮箱", to))