From 035aadb6d2969a80d10f7cd6a17c1aaa37aba4e3 Mon Sep 17 00:00:00 2001
From: Franklin-F <dewujie64@gmail.com>
Date: Sun, 1 Jun 2025 17:03:59 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E7=A7=BB=E9=99=A4=E4=B8=8D=E5=BF=85?=
 =?UTF-8?q?=E8=A6=81=E7=9A=84=E7=BB=9F=E8=AE=A1=E5=9B=9E=E6=BB=9A=E6=B3=A8?=
 =?UTF-8?q?=E9=87=8A=E4=BB=A5=E6=B8=85=E7=90=86=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 DB.py   | 2 +-
 main.py | 1 -
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/DB.py b/DB.py
index 963bb61..470cee6 100644
--- a/DB.py
+++ b/DB.py
@@ -534,7 +534,7 @@ class DBSA:
             cls._buf_vid.append(vid_row)
             cls._buf_payload.append(data)  # 保存原始
             buf_len = len(cls._buf_vid)
-            logger.info(f"DB缓冲 -> xid={data['v_xid']},    level={data['level']},    buffer={buf_len}")
+            # logger.info(f"DB缓冲 -> xid={data['v_xid']},    level={data['level']},    buffer={buf_len}")
 
             need_flush = False
             flush_reason = ""
diff --git a/main.py b/main.py
index 79a10c5..3ff4fa7 100644
--- a/main.py
+++ b/main.py
@@ -194,7 +194,6 @@ def integrate_data_parallel():
                     "level": kitem["level"],
                 })
             DBSA.flush()
-            exit()
         if rollback[0]:
             db.rollback_l0(rollback[0])
         if rollback[1]: