|
|
@@ -429,6 +429,7 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
|
|
|
select_day_recall = []
|
|
|
no_selected_recall = []
|
|
|
sim_hot_recall = []
|
|
|
+ flow_recall = []
|
|
|
flowFlag_dict = {}
|
|
|
for per_item in all_recall_result:
|
|
|
#print(per_item)
|
|
|
@@ -457,6 +458,8 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
|
|
|
no_selected_recall.append(per_item)
|
|
|
elif recall_name == config_.PUSH_FROM['sim_hot_vid_recall']:
|
|
|
sim_hot_recall.append(per_item)
|
|
|
+ elif recall_name == config_.PUSH_FROM['flow_recall']:
|
|
|
+ flow_recall.append(per_item)
|
|
|
if vId not in recall_dict:
|
|
|
recall_dict[vId] = recall_name
|
|
|
else:
|
|
|
@@ -504,7 +507,7 @@ def new_video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
|
|
|
#
|
|
|
print("rank_result:", rank_result)
|
|
|
else:
|
|
|
- all_dup_recall_result = region_h_recall+region_day_recall+select_day_recall+no_selected_recall
|
|
|
+ all_dup_recall_result = region_h_recall+region_day_recall+select_day_recall+no_selected_recall+flow_recall
|
|
|
rank_result = refactor_video_rank(rov_recall_rank=all_dup_recall_result,fast_flow_set=fast_flow_set, flow_set=flow_flow_set, size=size, top_K=top_K, flow_pool_P=float(flow_pool_P))
|
|
|
|
|
|
result['rankResult'] = rank_result
|
linfan