red-future/model-gateway
4
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/dev未优化' into dev未优化

Browse Source
This commit is contained in:
WangLiZhao
2026-07-01 15:17:26 +08:00
parent 2bc9d76e18 b00e5d34f4
commit 29d3f7ffb2
4 changed files with 156 additions and 132 deletions
Download Patch File Download Diff File Expand all files Collapse all files
service/task/worker.go
+5 -2
View File
@@ -49,7 +49,7 @@ func (w *asyncWorker) handleOne(ctx context.Context, task *entity.ModelGatewayTa
for attempt := 0; ; attempt++ {
if attempt > 0 {
g.Log().Infof(ctx, "[handleOne] 调模型重试 第%d次 taskId=%s", attempt, task.TaskID)
time.Sleep(time.Duration(attempt) * time.Second)
time.Sleep(time.Duration(attempt) * 5 * time.Second)
}
switch {
@@ -74,7 +74,10 @@ func (w *asyncWorker) handleOne(ctx context.Context, task *entity.ModelGatewayTa
if !strings.Contains(err.Error(), "Timeout") &&
!strings.Contains(err.Error(), "InternalServiceError") &&
!strings.Contains(err.Error(), "Invalid video_url") &&
!strings.Contains(err.Error(), "Invalid audio track") {
!strings.Contains(err.Error(), "Invalid audio track") &&
!strings.Contains(err.Error(), "Error while downloading") &&
!strings.Contains(err.Error(), "Error while connecting") &&
!strings.Contains(err.Error(), "download failed") {
w.failTask(ctx, task, startTime, err.Error())
return
}