|
|
@@ -107,7 +107,10 @@ async def get_mid_group_mapping(feature_df, group_list):
|
|
|
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)
|
|
|
- log_.info(f"group = {group} mid mapping finished! execute time = {(time.time() - start_time) / 60}min")
|
|
|
+ global mids_global, mid_group_mapping_global
|
|
|
+ log_.info(f"group = {group} mid mapping finished! "
|
|
|
+ f"mid_count = {len(mids_global)}, mid_group_mapping_count = {len(mid_group_mapping_global)}, "
|
|
|
+ f"execute time = {(time.time() - start_time) / 60}min")
|
|
|
|
|
|
# for mid in mid_list:
|
|
|
# if mid is None:
|
