add log

recommend.py

@@ -216,6 +216,7 @@ 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:
@@ -449,6 +450,7 @@ 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)]
@@ -1821,6 +1823,7 @@ 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,6 +439,7 @@ 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()]
@@ -528,6 +529,7 @@ 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(
@@ -676,6 +678,7 @@ 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()]