debug

video_recall.py

@@ -173,7 +173,7 @@ class PoolRecall(object):
         check_result = []
         for video_id in video_ids:
             video_id = int(video_id)
-            for flow_pool in flow_pool_mapping[video_id]:
+            for flow_pool in flow_pool_mapping.get(video_id, []):
                 # 判断是否有本地分发记录
                 cur_count = get_videos_local_distribute_count(video_id=video_id, flow_pool=flow_pool)
                 # 无记录