|
|
@@ -2380,10 +2380,9 @@ class PoolRecall(object):
|
|
|
print("json_result:", json_result)
|
|
|
for per_item in json_result:
|
|
|
try:
|
|
|
- print(per_item)
|
|
|
vid = int(per_item[0])
|
|
|
video_ids.append(vid)
|
|
|
- recall_dict[vid] = {'videoId': per_item[0], 'flowPool': '',
|
|
|
+ recall_dict[vid] = {'videoId': vid, 'flowPool': '',
|
|
|
'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['hot_3_day_recall'],
|
|
|
'abCode': self.ab_code}
|
|
|
except Exception as e:
|
|
|
@@ -2422,7 +2421,7 @@ class PoolRecall(object):
|
|
|
try:
|
|
|
vid = int(per_item[0])
|
|
|
video_ids.append(vid)
|
|
|
- recall_dict[vid] = {'videoId': per_item[0], 'flowPool': '',
|
|
|
+ recall_dict[vid] = {'videoId': vid, 'flowPool': '',
|
|
|
'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['hot_7_day_recall'],
|
|
|
'abCode': self.ab_code}
|
|
|
except Exception as e:
|
|
|
@@ -2440,4 +2439,5 @@ class PoolRecall(object):
|
|
|
for vid in filtered_viewed_videos:
|
|
|
if vid in recall_dict:
|
|
|
recall_result.append(recall_dict[vid])
|
|
|
+ print("hot recall_result:", recall_result)
|
|
|
return recall_result
|
linfan