From b6cdb8ff1dc877e29ed13a5b65e77ed6a48111df Mon Sep 17 00:00:00 2001 From: WangLiZhao <1838393649@qq.com> Date: Thu, 21 May 2026 14:23:34 +0800 Subject: [PATCH] =?UTF-8?q?refactor(prompt):=20=E4=BC=98=E5=8C=96=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E7=AD=89=E5=BE=85=E6=9C=BA=E5=88=B6=E5=B9=B6=E6=94=B9?= =?UTF-8?q?=E8=BF=9B=E6=95=B0=E6=8D=AE=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- service/gateway/gateway_http_service.go | 2 +- service/task_service.go | 2 -- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/service/gateway/gateway_http_service.go b/service/gateway/gateway_http_service.go index 06b0132..e9edb30 100644 --- a/service/gateway/gateway_http_service.go +++ b/service/gateway/gateway_http_service.go @@ -45,7 +45,7 @@ func UploadByTask(ctx context.Context, _ *entity.AsynchTask, data []byte, fileEx return "", err } contentType := writer.FormDataContentType() - if err := writer.Close(); err != nil { + if err = writer.Close(); err != nil { return "", err } diff --git a/service/task_service.go b/service/task_service.go index 2a604cd..f656be2 100644 --- a/service/task_service.go +++ b/service/task_service.go @@ -104,7 +104,6 @@ func (s *taskService) Create(ctx context.Context, req *dto.CreateTaskReq) (res * // 4) 创建成功后立即异步尝试执行当前任务,并仅在任务仍处于 pending(state=0) 时做定向轮询。 // 一旦任务进入 running/success/failed/downloaded,就停止轮询,避免一直空转。 go s.pollAndRunUntilPicked(context.WithoutCancel(ctx), taskID, req.EpicycleId) - return &dto.CreateTaskRes{TaskID: taskID}, nil } @@ -162,7 +161,6 @@ func (s *taskService) pollAndRunUntilPicked(ctx context.Context, taskID string, if stop := tryRun(); stop { return } - for { select { case <-ctx.Done():