From 2d75510c5933c81ad9d8621de998ff21c67d93d4 Mon Sep 17 00:00:00 2001
From: Franklin-F <dewujie64@gmail.com>
Date: Wed, 21 May 2025 08:37:18 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E6=B7=BB=E5=8A=A0=20=5Fbuf=5Fpayload?=
 =?UTF-8?q?=20=E7=BC=93=E5=86=B2=E5=8C=BA=E4=BB=A5=E5=A2=9E=E5=BC=BA=20DB.?=
 =?UTF-8?q?py=20=E7=9A=84=E6=95=B0=E6=8D=AE=E5=A4=84=E7=90=86=E8=83=BD?=
 =?UTF-8?q?=E5=8A=9B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/main.py b/main.py
index af1046f..6cee59f 100644
--- a/main.py
+++ b/main.py
@@ -658,7 +658,8 @@ def search_worker(payload, kitem, flag):
                 if v_list:
                     break
                 time.sleep(2)
-
+        if not v_list:
+            v_list = []
         return True, flag, payload, kitem, v_list  # 成功
     except Exception as e:
         print(f"[线程异常] {kitem['keyword']} → {e}")
@@ -691,8 +692,9 @@ def integrate_data_parallel():
                 rollback[f_flag].append(payload)
                 continue
 
-            # —— 写库：可按你原来的 upsert / flush 逻辑 ——
             for item in v_list:
+                if not v_list:
+                    continue
                 DBSA.upsert_video({
                     "keyword": kitem["keyword"],
                     "v_name": kitem["v_name"],