update

recommend.py

@@ -216,7 +216,6 @@ def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, al
     elif ab_code == 60064:
         exp_config = pool_recall.get_video_recall_config()
     #print("exp_config:", exp_config)
-    log_.info(f"flow_pool_abtest_group0: {flow_pool_abtest_group}")
     if app_type in [config_.APP_TYPE['LAO_HAO_KAN_VIDEO'], config_.APP_TYPE['ZUI_JING_QI']]:
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time)]
         # if ab_code == 60058:
@@ -454,7 +453,6 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
                              video_id=video_id, level_weight=level_weight)
 
     exp_config = pool_recall.get_sort_ab_codel_config()
-    log_.info(f"flow_pool_abtest_group0: {flow_pool_abtest_group}")
     # 60054 全量： simrecall+融合排序
     if app_type in [config_.APP_TYPE['LAO_HAO_KAN_VIDEO'], config_.APP_TYPE['ZUI_JING_QI']]:
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time)]
@@ -1831,7 +1829,6 @@ def video_homepage_recommend(request_id, mid, uid, size, app_type, algo_type,
     #     'executeTime': (time.time() - param_st) * 1000
     # })
     recommend_result['getRecommendParamsTime'] = (time.time() - param_st) * 1000
-    log_.info(f"flow_pool_abtest_group00: {flow_pool_abtest_group}")
 
     # 简单召回 - 排序 - 兜底
     get_result_st = time.time()

video_recall.py

@@ -439,7 +439,6 @@ class PoolRecall(object):
 
     def flow_pool_recall(self, size=10, flow_pool_id=None, flow_pool_abtest_group=None):
         """从流量池中获取视频"""
-        log_.info(f"flow_pool_abtest_group1: {flow_pool_abtest_group}")
         start_time = time.time()
         # 获取存在城市分组数据的城市编码列表
         city_code_list = [code for _, code in config_.CITY_CODE.items()]
@@ -529,7 +528,6 @@ class PoolRecall(object):
                     video_id = int(item[0])
                     flow_pool = item[1]
                     if video_id not in flow_pool_recall_videos:
-                        log_.info(f"flow_pool_abtest_group: {flow_pool_abtest_group}")
                         # 取其中一个 flow_pool 作为召回结果
                         # 添加视频源参数 pushFrom, abCode
                         flow_pool_recall_result.append(
@@ -678,7 +676,6 @@ class PoolRecall(object):
 
     def flow_pool_recall_new_with_level(self, size=10, flow_pool_id=None, flow_pool_abtest_group=None):
         """从流量池中获取视频"""
-        log_.info(f"flow_pool_abtest_group1: {flow_pool_abtest_group}")
         start_time = time.time()
         # 获取存在城市分组数据的城市编码列表
         city_code_list = [code for _, code in config_.CITY_CODE.items()]
@@ -769,7 +766,6 @@ class PoolRecall(object):
                     if video_id not in flow_pool_recall_videos:
                         # 取其中一个 flow_pool 作为召回结果
                         # 添加视频源参数 pushFrom, abCode
-                        log_.info(f"flow_pool_abtest_group: {flow_pool_abtest_group}")
                         flow_pool_recall_result.append(
                             {'videoId': video_id, 'flowPool': flow_pool, 'level': level,
                              'rovScore': random.uniform(0, 100), 'pushFrom': config_.PUSH_FROM['flow_recall'],