diff --git a/main.py b/main.py index af94db0..f752b0b 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(20) + tasks, flag = db.item_keyword(1) if not tasks: time.sleep(10) continue @@ -194,6 +194,7 @@ def integrate_data_parallel(): "level": kitem["level"], }) DBSA.flush() + exit() if rollback[0]: db.rollback_l0(rollback[0]) if rollback[1]: