|
|
@@ -383,6 +383,8 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
|
|
|
|
|
|
gevent.joinall(t)
|
|
|
recall_result_list = [i.get() for i in t]
|
|
|
+
|
|
|
+ print(recall_result_list)
|
|
|
if len(recall_result_list)<0:
|
|
|
result['recallResult']= []
|
|
|
result['rankResult'] = []
|
|
|
@@ -392,6 +394,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
|
|
|
if len(recall_result_list)>=4:
|
|
|
region_recall = recall_result_list[0]
|
|
|
sim_recall = recall_result_list[3]
|
|
|
+ print("sim:",sim_recall)
|
|
|
now_video_ids = set('')
|
|
|
if len(region_recall)>0:
|
|
|
for video in region_recall:
|
|
|
@@ -402,6 +405,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
|
|
|
if len(sim_recall)>0:
|
|
|
for video in sim_recall:
|
|
|
video_id = video.get('videoId')
|
|
|
+ print("sim video_id:", video_id)
|
|
|
if video_id not in now_video_ids:
|
|
|
rov_pool_recall.append(video)
|
|
|
now_video_ids.add(video_id)
|
linfan