From 3b448a5ed33e98f385530dc08d977afcee757d94 Mon Sep 17 00:00:00 2001
From: Franklin-F <dewujie64@gmail.com>
Date: Mon, 2 Jun 2025 22:35:22 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E5=A4=84=E7=90=86=E9=80=BB=E8=BE=91=EF=BC=8C=E5=87=8F=E5=B0=91?=
 =?UTF-8?q?=E5=B9=B6=E5=8F=91=E8=AF=B7=E6=B1=82=E9=97=B4=E9=9A=94=E4=BB=A5?=
 =?UTF-8?q?=E6=8F=90=E9=AB=98=E6=95=88=E7=8E=87?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main.py | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/main.py b/main.py
index 63954e3..73f0df2 100644
--- a/main.py
+++ b/main.py
@@ -163,10 +163,11 @@ def integrate_data_parallel():
             time.sleep(10)
             continue
 
-        futures = [
-            executor.submit(search_worker, payload, kitem, flag)
-            for payload, kitem in tasks
-        ]
+        futures = []
+        for payload, kitem in tasks:
+            futures.append(executor.submit(search_worker, payload, kitem, flag))
+            time.sleep(3)
+
         rollback = {0: [], 1: [], 2: []}
 
         for fut in concurrent.futures.as_completed(futures):
@@ -209,7 +210,6 @@ def integrate_data_parallel():
             db.rollback_l1(rollback[1])
         if rollback[2]:
             db.rollback_l2(rollback[2])
-        time.sleep(10)
 
 
 def parse_args() -> argparse.Namespace: