From e85e8dffb3d9a9e0fea916d6d67ab1b5e6ed1ade Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=80=97=E5=AD=90?= Date: Mon, 4 Nov 2024 17:48:46 +0800 Subject: [PATCH] fix: lint --- internal/data/task.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/data/task.go b/internal/data/task.go index ade1d7e6..e6fe70ab 100644 --- a/internal/data/task.go +++ b/internal/data/task.go @@ -53,7 +53,7 @@ func (r *taskRepo) Push(task *biz.Task) error { return err } if count > 0 { - return fmt.Errorf("任务重复提交,请等待上一个任务完成") + return fmt.Errorf("duplicate submission, please wait for the previous task to end") } if err := app.Orm.Create(task).Error; err != nil { @@ -73,7 +73,7 @@ func (r *taskRepo) DispatchWaiting() { var tasks []biz.Task if err := app.Orm.Where("status = ?", biz.TaskStatusWaiting).Find(&tasks).Error; err != nil { - app.Logger.Warn("获取待处理任务失败", slog.Any("err", err)) + app.Logger.Warn("failed to get pending tasks", slog.Any("err", err)) return } @@ -81,7 +81,7 @@ func (r *taskRepo) DispatchWaiting() { if err := app.Queue.Push(queuejob.NewProcessTask(r), []any{ task.ID, }); err != nil { - app.Logger.Warn("推送任务失败", slog.Any("err", err)) + app.Logger.Warn("failed to push task", slog.Any("err", err)) return } }