|
@@ -33,7 +33,7 @@ def update_user_group_to_redis(project, table, dt, app_type):
|
|
|
mid_list = feature_df[group].tolist()
|
|
mid_list = feature_df[group].tolist()
|
|
|
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=5)
|
|
+ pool = multiprocessing.Pool(processes=2)
|
|
|
for mid in mid_list:
|
|
for mid in mid_list:
|
|
|
key_name = f"{config_.KEY_NAME_PREFIX_MID_GROUP}{mid}"
|
|
key_name = f"{config_.KEY_NAME_PREFIX_MID_GROUP}{mid}"
|
|
|
pool.apply_async(
|
|
pool.apply_async(
|
