sync redis

flowpool_data_update_with_level_score_v2.py

@@ -171,7 +171,7 @@ def update_flow_pool(flow_pool_id_list):
         # 普通流量池视频按照层级存储
         flow_pool_redis_data = dict()
         level_weight = dict()
-        for video_id in remain_videos:
+        for video_id, distribute_count in remain_videos.items():
             for item in mapping.get(video_id):
                 flow_pool = item['flowPool']
                 level = item['level']