diff --git a/main.py b/main.py index f752b0b..af94db0 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(1) + tasks, flag = db.item_keyword(20) if not tasks: time.sleep(10) continue @@ -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]: