From 39b61f1867bfe9cefab5dd095e3d9bd3356ff4dc Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Mon, 22 Jun 2026 09:08:12 +0800
Subject: [PATCH] =?UTF-8?q?chore:=20=E6=9B=B4=E6=96=B0=E9=85=8D=E7=BD=AE?=
 =?UTF-8?q?=E5=B9=B6=E4=BC=98=E5=8C=96=E4=BB=BB=E5=8A=A1=E9=94=99=E8=AF=AF?=
 =?UTF-8?q?=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

将数据库、Redis、Consul及Jaeger配置切换至新环境地址，并在worker中忽略"Invalid video_url"与"Invalid audio track"错误，同时补充模型调用成功日志。
---
 config.yml             | 12 ++++++------
 service/task/worker.go |  5 ++++-
 2 files changed, 10 insertions(+), 7 deletions(-)

diff --git a/config.yml b/config.yml
index 8da4bef..dafc77f 100644
--- a/config.yml
+++ b/config.yml
@@ -28,10 +28,10 @@ database:
       timeMaintainDisabled: false # (可选)是否完全关闭时间更新特性，为true时CreatedAt/UpdatedAt/DeletedAt都将失效
   model_gateway:
     - type: "pgsql"
-      host: "192.168.3.30"
-      port: "5432"
+      host: "116.204.74.41"
+      port: "15432"
       user: "postgres"
-      pass: "123456"
+      pass: "Bjang09@686^*^"
       name: "model-gateway"
       prefix: ""
       role: "master"
@@ -50,14 +50,14 @@ database:
 
 redis:
   default:
-    address: 192.168.3.30:6379
+    address: 116.204.74.41:6379
     db: 0
 
 consul:
-  address: 192.168.3.30:8500
+  address: 116.204.74.41:8500
 
 jaeger:
-  addr: 192.168.3.30:4318
+  addr: 116.204.74.41:4318
 
 # 本地调试用：可选自动执行 worker/cleaner（默认关闭）
 asynch:
diff --git a/service/task/worker.go b/service/task/worker.go
index 20dd537..6ed9db5 100644
--- a/service/task/worker.go
+++ b/service/task/worker.go
@@ -72,7 +72,9 @@ 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(), "InternalServiceError") &&
+			!strings.Contains(err.Error(), "Invalid video_url") &&
+			!strings.Contains(err.Error(), "Invalid audio track") {
 			w.failTask(ctx, task, startTime, err.Error())
 			return
 		}
@@ -395,6 +397,7 @@ func InvokeModel(ctx context.Context, model *entity.ModelGatewayModel, body map[
 		msg := string(b)
 		return nil, fmt.Errorf("模型服务返回非2xx: %d, body=%s", resp.StatusCode, msg)
 	}
+	g.Log().Debugf(ctx, "[执行任务][模型调用成功] StatusCode=%v", resp.StatusCode)
 	return b, nil
 }