Merge branch 'feature_2023101920_liqian_debug' into test

flowpool_data_update_with_level.py

@@ -90,8 +90,10 @@ def get_videos_remain_view_count(video_info_list):
                 # 从流量召回池移除
                 value = '{}-{}'.format(item['videoId'], item['flowPool'])
                 for type_name in config_.APP_TYPE:
-                    flow_pool_key = f"{config_.FLOWPOOL_KEY_NAME_PREFIX_SET}{config_.APP_TYPE.get(type_name)}"
-                    redis_helper.remove_value_from_set(key_name=flow_pool_key, values=(value, ))
+                    for level in range(1, 7):
+                        flow_pool_key = \
+                            f"{config_.FLOWPOOL_KEY_NAME_PREFIX_SET_LEVEL}{config_.APP_TYPE.get(type_name)}:{level}"
+                        redis_helper.remove_value_from_set(key_name=flow_pool_key, values=(value, ))
                     quick_flow_pool_key = f"{config_.QUICK_FLOWPOOL_KEY_NAME_PREFIX_SET}{config_.APP_TYPE.get(type_name)}" \
                                           f":{config_.QUICK_FLOW_POOL_ID}"
                     redis_helper.remove_value_from_set(key_name=quick_flow_pool_key, values=(value, ))