From e11155b6049b2e7525dd5d6770f0b4753a108a80 Mon Sep 17 00:00:00 2001
From: qhd <1766646056@qq.com>
Date: Thu, 25 Jun 2026 11:07:07 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=BF=BD=E7=95=A5=E8=BF=9E=E6=8E=A5?=
 =?UTF-8?q?=E9=94=99=E8=AF=AF=E4=BB=A5=E9=81=BF=E5=85=8D=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E8=AF=AF=E5=88=A4=E5=A4=B1=E8=B4=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 service/task/worker.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/service/task/worker.go b/service/task/worker.go
index 8816381..12c16c6 100644
--- a/service/task/worker.go
+++ b/service/task/worker.go
@@ -75,7 +75,8 @@ func (w *asyncWorker) handleOne(ctx context.Context, task *entity.ModelGatewayTa
 			!strings.Contains(err.Error(), "InternalServiceError") &&
 			!strings.Contains(err.Error(), "Invalid video_url") &&
 			!strings.Contains(err.Error(), "Invalid audio track") &&
-			!strings.Contains(err.Error(), "Error while downloading") {
+			!strings.Contains(err.Error(), "Error while downloading") &&
+			!strings.Contains(err.Error(), "Error while connecting") {
 			w.failTask(ctx, task, startTime, err.Error())
 			return
 		}