|
|
@@ -99,11 +99,12 @@ async def get_mid_group_mapping(feature_df, group_list):
|
|
|
# pool.close()
|
|
|
# pool.join()
|
|
|
|
|
|
- step = len(mid_list) // (10 - 1)
|
|
|
+ step = len(mid_list) // (100 - 1)
|
|
|
loop = asyncio.get_running_loop()
|
|
|
- executor = ThreadPoolExecutor(max_workers=10)
|
|
|
+ executor = ThreadPoolExecutor(max_workers=20)
|
|
|
tasks = []
|
|
|
- for i in range(10 + 1):
|
|
|
+ for i in range(100 + 1):
|
|
|
+ log_.info(f"i = {i}")
|
|
|
process_mid_list = mid_list[i * step:(i + 1) * step]
|
|
|
tasks.append(loop.run_in_executor(executor, mapping_process, group, process_mid_list))
|
|
|
await asyncio.wait(tasks)
|
