Merge branch 'debug-timeout' into test

recommend.py

@@ -124,6 +124,7 @@ def update_local_distribute_count(videos):
             #     redis_helper.incr_key(key_name=key_name, amount=int(item['distributeCount']) - 1, expire_time=5 * 60)
 
     except Exception as e:
+        log_.error('update_local_distribute_count error...')
         log_.error(traceback.format_exc())
 
 

utils.py

@@ -208,6 +208,10 @@ class FilterVideos(object):
 
 
 if __name__ == '__main__':
-    filter_ = FilterVideos(app_type=1, mid='22', uid='www', video_ids=[1, 2, 3, 55])
-    filter_.filter_videos()
-    filter_.filter_video_status(video_ids=[1, 3, 5])
+    # filter_ = FilterVideos(app_type=1, mid='22', uid='www', video_ids=[1, 2, 3, 55])
+    # filter_.filter_videos()
+    # filter_.filter_video_status(video_ids=[1, 3, 5])
+
+    videos = [{'videoId': 9034659, 'flowPool': '3#11#3#1637824188547'}, {'videoId': 9035052, 'flowPool': '3#11#3#1637824172827'}]
+    res = get_videos_remain_view_count(4, videos)
+    print(res)

video_recall.py

@@ -201,6 +201,7 @@ class PoolRecall(object):
         redis_helper = RedisHelper()
         for item in view_count_result:
             try:
+                # 接口超时，item[2]可能为None
                 remain_count = int(item[2])
             except Exception as e:
                 log_.error('remain_count type error...')