@@ -255,6 +255,8 @@ def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, al
# 'recall_result': recall_result_list,
# 'executeTime': (time.time() - start_recall) * 1000
# })
+
result['recallResult'] = recall_result_list
result['recallTime'] = (time.time() - start_recall) * 1000
@@ -313,6 +315,7 @@ def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, al
# rank_result = video_new_rank(data=data, size=size, top_K=top_K, flow_pool_P=float(flow_pool_P))
#else:
#print("data['hot_recall']", data['hot_recall'])
+ print('recallResult len', len(recall_result_list[0]))
if ab_code == 60058 or ab_code == 60059 or ab_code == 60060 or ab_code == 60061 :
test_config = None
flow_config = None
@@ -1330,6 +1330,7 @@ class PoolRecall(object):
item['flowPool'] = flow_pool
item['isInFlowPool'] = 1
result.append(item)
+ print("videos size:", len(videos), size)
return result
def get_video_flow_pool(self, video_id, quick_flow_pool=False):