|
|
@@ -571,7 +571,7 @@ def rank_by_h(project, table, now_date, now_h, rule_params, region_code_list, ru
|
|
|
rule_params_item = rule_params.get('rule_params')
|
|
|
params_list = rule_params.get('params_list')
|
|
|
pool = multiprocessing.Pool(processes=len(params_list))
|
|
|
- for param in params_list[0:1]:
|
|
|
+ for param in params_list:
|
|
|
pool.apply_async(
|
|
|
func=process_with_param,
|
|
|
args=(param, data_params_item, rule_params_item, region_code_list, feature_df, now_date, now_h, rule_rank_h_flag)
|
