|
@@ -609,7 +609,7 @@ def video_new_rank2(data, size, top_K, flow_pool_P, ab_code, mid, exp_config=Non
|
|
|
# 60054: simrecall,
|
|
|
pre_str = "k_p2:"
|
|
|
rov_recall_rank = data['rov_pool_recall']
|
|
|
- print(rov_recall_rank)
|
|
|
+ #print(rov_recall_rank)
|
|
|
#call rank service
|
|
|
#flag_call_service = 0
|
|
|
sort_index = 0
|
|
@@ -635,14 +635,14 @@ def video_new_rank2(data, size, top_K, flow_pool_P, ab_code, mid, exp_config=Non
|
|
|
except:
|
|
|
continue
|
|
|
video_scores = redisObj.get_batch_key(vidKeys)
|
|
|
- print("video_scores:", video_scores)
|
|
|
+ #print("video_scores:", video_scores)
|
|
|
if (ab_code == 60066 or ab_code == 60069 or ab_code == 60070 or ab_code == 60071) and len(rec_recall_vid_list)>0:
|
|
|
video_static_info = redisObj.get_batch_key(day_vidKeys)
|
|
|
video_hour_static_info = redisObj.get_batch_key(hour_vidKeys)
|
|
|
#print("env_dict:", env_dict)
|
|
|
feature_dict = get_featurs(mid, data, size, top_K, flow_pool_P, rec_recall_vid_list,env_dict, video_static_info, video_hour_static_info)
|
|
|
score_result = get_tf_serving_sores(feature_dict)
|
|
|
- print("score_result:", score_result)
|
|
|
+ #print("score_result:", score_result)
|
|
|
if video_scores and len(video_scores)>0 and rec_recall_item_list and score_result and len(score_result) > 0\
|
|
|
and len(score_result) == len(rec_recall_item_list) and len(video_scores)== len(score_result):
|
|
|
for i in range(len(score_result)):
|
|
@@ -669,7 +669,7 @@ def video_new_rank2(data, size, top_K, flow_pool_P, ab_code, mid, exp_config=Non
|
|
|
return_score)
|
|
|
rec_recall_item_list[i]['sort_score'] = total_score
|
|
|
except Exception as e:
|
|
|
- print('exception: {}:', e)
|
|
|
+ #print('exception: {}:', e)
|
|
|
if sort_index == 10:
|
|
|
total_score = 0.00000001
|
|
|
else:
|