sync redis

flowpool_data_update_with_level_score_v2.py

@@ -173,7 +173,7 @@ def update_flow_pool(flow_pool_id_list):
         for video_id in remain_videos:
             for item in mapping.get(video_id):
                 flow_pool = item['flowPool']
-				level = item['level']
+                level = item['level']
                 try:
                     score = float(item['score'])
                 except:
@@ -184,10 +184,10 @@ def update_flow_pool(flow_pool_id_list):
                     quick_flow_pool_redis_data[value] = score
                 else:                    
                     if level not in flow_pool_redis_data:
-					    flow_pool_redis_data[level]=dict()
-						level_weight[level] = 0
-					flow_pool_redis_data[level][value] = score
-					level_weight[level]=level_weight[level]+distribute_count
+                        flow_pool_redis_data[level]=dict()
+                        level_weight[level] = 0
+                    flow_pool_redis_data[level][value] = score
+                    level_weight[level]=level_weight[level]+distribute_count
         # 2. quick曝光池
         redis_helper = RedisHelper()
         quick_flow_pool_key_name = f"{config_.QUICK_FLOWPOOL_KEY_NAME_PREFIX}{app_type}:{config_.QUICK_FLOW_POOL_ID}"