diff --git a/main.py b/main.py index 883cb09..79a10c5 100644 --- a/main.py +++ b/main.py @@ -158,7 +158,6 @@ def integrate_data_parallel(): executor.submit(search_worker, payload, kitem, flag) for payload, kitem in tasks ] - # 统计回滚 rollback = {0: [], 1: [], 2: []} for fut in concurrent.futures.as_completed(futures):