diff --git a/main.py b/main.py
index 9893f28..883cb09 100644
--- a/main.py
+++ b/main.py
@@ -149,7 +149,7 @@ def integrate_data_parallel():
     while True:
         global proxiesdict
         proxiesdict = db.get_proxy_agent_dict()
-        tasks, flag = db.item_keyword()
+        tasks, flag = db.item_keyword(1)
         if not tasks:
             time.sleep(10)
             continue
@@ -195,6 +195,7 @@ def integrate_data_parallel():
                     "level": kitem["level"],
                 })
             DBSA.flush()
+            exit()
         if rollback[0]:
             db.rollback_l0(rollback[0])
         if rollback[1]: