video_recall.py

video_recall.py

@@ -2137,11 +2137,13 @@ class PoolRecall(object):
             json_result = json.loads(data)
             # print("json_result:", json_result)
             for per_item in json_result:
-                video_ids.append(per_item[0])
-                recall_dict[per_item[0]] = {'videoId': per_item[0], 'flowPool': '',
-                     'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['sim_hot_vid_recall'],
-                     'abCode': self.ab_code}
-
+                try:
+                    video_ids.append(int(per_item[0]))
+                    recall_dict[per_item[0]] = {'videoId': per_item[0], 'flowPool': '',
+                         'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['sim_hot_vid_recall'],
+                         'abCode': self.ab_code}
+                except Exception as e:
+                    continue
         if len(video_ids)<=0:
             return  recall_result
         video_ids = video_ids[:50]