|
@@ -44,7 +44,7 @@ def update_user_group_to_redis(project, table, dt, app_type):
|
|
|
mid_list = list(set(mid_list))
|
|
mid_list = list(set(mid_list))
|
|
|
mid_list = [mid for mid in mid_list if mid is not None]
|
|
mid_list = [mid for mid in mid_list if mid is not None]
|
|
|
log_.info(f"mid count = {len(mid_list)}")
|
|
log_.info(f"mid count = {len(mid_list)}")
|
|
|
- pool = multiprocessing.Pool(processes=2)
|
|
|
|
|
|
|
+ pool = multiprocessing.Pool(processes=multiprocessing.cpu_count())
|
|
|
for i in range(len(mid_list)//100+1):
|
|
for i in range(len(mid_list)//100+1):
|
|
|
log_.info(f"i = {i}")
|
|
log_.info(f"i = {i}")
|
|
|
mid_temp_list = mid_list[i*100:(i+1)*100]
|
|
mid_temp_list = mid_list[i*100:(i+1)*100]
|
