|
|
@@ -281,7 +281,7 @@ def process_with_param(param, data_params_item, rule_params_item, region_code_li
|
|
|
for region in region_code_list
|
|
|
]
|
|
|
else:
|
|
|
- df_list = [feature_df[feature_df['apptype'] == apptype] for apptype in data_param]
|
|
|
+ df_list = [feature_df[feature_df['apptype'] == apptype] for apptype, _ in data_param.items()]
|
|
|
df_merged = reduce(merge_df, df_list)
|
|
|
task_list = [
|
|
|
gevent.spawn(process_with_region, region, df_merged, data_key, rule_key, rule_param, now_date, now_h)
|
liqian