@@ -164,7 +164,12 @@ def video_new_rank(videoIds, fast_flow_set, flow_set, size, top_K, flow_pool_P):
return []
redisObj = RedisHelper()
- video_scores = redisObj.get_batch_key(videoIds)
+ vidKeys = []
+ for vid in videoIds:
+ vidKeys.append("k_p:"+str(vid))
+ print("vidKeys:", vidKeys)
+ video_scores = redisObj.get_batch_key(vidKeys)
+ print(video_scores)
video_items = []
for i in range(len(video_scores)):
try: