|
|
@@ -97,7 +97,7 @@ def update_user_group_to_redis(project, table, dt, app_type_list, features, ad_m
|
|
|
mid_group_mapping, mids = get_mid_group_mapping(feature_df=feature_df, group_list=group_list)
|
|
|
|
|
|
pool = multiprocessing.Pool(processes=len(ad_mid_group_key_params))
|
|
|
- step = len(mids) / (len(ad_mid_group_key_params) - 1)
|
|
|
+ step = len(mids) // (len(ad_mid_group_key_params) - 1)
|
|
|
for i in range(len(ad_mid_group_key_params) + 1):
|
|
|
process_mid_list = mids[i*step:(i+1)*step]
|
|
|
pool.apply_async(func=to_redis2, args=(process_mid_list, mid_group_mapping, ad_mid_group_key_params))
|
