Explorar el Código

全量过滤 增加链接时间

zhangbo hace 1 año
padre
commit
bce1581f21
Se han modificado 1 ficheros con 3 adiciones y 3 borrados
  1. 3 3
      recommend.py

+ 3 - 3
recommend.py

@@ -142,7 +142,7 @@ def positon_duplicate(pos1_vids, pos2_vids, videos):
 def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, algo_type, client_info,
                     expire_time=24*3600, ab_code=config_.AB_CODE['initial'], rule_key='', data_key='',
                     no_op_flag=False, old_video_index=-1, video_id=None, params=None, rule_key_30day=None,
-                    shield_config=None, level_weight=None, flow_pool_abtest_group=None):
+                    shield_config=None, level_weight=None, flow_pool_abtest_group=None, env_dict=None):
     """
     首页线上推荐逻辑
     :param request_id: request_id
@@ -185,7 +185,7 @@ def video_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type, al
                              app_type=app_type, mid=mid, uid=uid, ab_code=ab_code,
                              client_info=client_info, rule_key=rule_key, data_key=data_key, no_op_flag=no_op_flag,
                              params=params, rule_key_30day=rule_key_30day, shield_config=shield_config,
-                             video_id= video_id, level_weight=level_weight)
+                             video_id= video_id, level_weight=level_weight, env_dict=env_dict)
     # _, last_rov_recall_key, _ = pool_recall.get_video_last_idx()
     # # 小时级实验
     # if ab_code in [code for _, code in config_.AB_CODE['rank_by_h'].items()]:
@@ -2044,7 +2044,7 @@ def video_homepage_recommend(request_id, mid, uid, size, app_type, algo_type,
                                  ab_code=ab_code, expire_time=expire_time, rule_key=rule_key, data_key=data_key,
                                  no_op_flag=no_op_flag, old_video_index=old_video_index, params=params,
                                  rule_key_30day=rule_key_30day, shield_config=shield_config, level_weight=level_weight,
-                                 flow_pool_abtest_group=flow_pool_abtest_group)
+                                 flow_pool_abtest_group=flow_pool_abtest_group, env_dict=env_dict)
     # log_.info({
     #     'logTimestamp': int(time.time() * 1000),
     #     'request_id': request_id,