From ea2825bef90c1d66ebcf92fc450bac4765ea26e5 Mon Sep 17 00:00:00 2001 From: Franklin-F Date: Mon, 2 Jun 2025 23:31:22 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=B0=83=E6=95=B4=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=BA=93=E5=88=B7=E6=96=B0=E9=97=B4=E9=9A=94=E5=92=8C=E8=AF=B7?= =?UTF-8?q?=E6=B1=82=E5=BB=B6=E8=BF=9F=E4=BB=A5=E4=BC=98=E5=8C=96=E6=80=A7?= =?UTF-8?q?=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- DB.py | 2 +- main.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/DB.py b/DB.py index be2a6ee..9f83c81 100644 --- a/DB.py +++ b/DB.py @@ -503,7 +503,7 @@ class DBVidcon: class DBSA: FLUSH_EVERY_ROWS = 100 # 行阈值 - FLUSH_INTERVAL = 30 # 秒阈值 + FLUSH_INTERVAL = 40 # 秒阈值 _buf_op: List[Dict] = [] _buf_vid: List[Dict] = [] diff --git a/main.py b/main.py index a91bb04..8a9eae2 100644 --- a/main.py +++ b/main.py @@ -165,7 +165,7 @@ def integrate_data_parallel(): futures = [] for payload, kitem in tasks: futures.append(executor.submit(search_worker, payload, kitem, flag)) - time.sleep(3) + time.sleep(1) rollback = {0: [], 1: [], 2: []}