fix: 移除不必要的统计回滚注释以清理代码

This commit is contained in:
晓丰 2025-06-01 16:55:26 +08:00
parent 501edbc398
commit af948c48e6

View File

@ -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):