zhangbo пре 1 година
родитељ
комит
08df9cae40
3 измењених фајлова са 5 додато и 4 уклоњено
  1. 1 1
      config.py
  2. 3 3
      recommend.py
  3. 1 0
      video_recall.py

+ 1 - 1
config.py

@@ -577,7 +577,7 @@ class BaseConfig(object):
         },  #
         },  #
         '533': {
         '533': {
             'data_key': 'data66', 'rule_key': 'rule66',
             'data_key': 'data66', 'rule_key': 'rule66',
-            'ab_code': AB_CODE['region_rank_by_h'].get('abtest_523'),
+            'ab_code': AB_CODE['region_rank_by_h'].get('abtest_533'),
         },  # 新增一路召回趋势性
         },  # 新增一路召回趋势性
 
 
     }
     }

+ 3 - 3
recommend.py

@@ -539,10 +539,10 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
             or ab_code == 60092 or ab_code == 60093 or ab_code == 60094 or ab_code == 60095 or ab_code == 60096\
             or ab_code == 60092 or ab_code == 60093 or ab_code == 60094 or ab_code == 60095 or ab_code == 60096\
             or ab_code == 60097:
             or ab_code == 60097:
         t.append(gevent.spawn(pool_recall.get_sim_hot_item_reall_filter))
         t.append(gevent.spawn(pool_recall.get_sim_hot_item_reall_filter))
-        t.append(gevent.spawn(pool_recall.recall_strategy_trend_v1, 'rv2:'))
+        t.append(gevent.spawn(pool_recall.get_return_video_reall, 'rv2:'))
     elif ab_code == 60098:
     elif ab_code == 60098:
         t.append(gevent.spawn(pool_recall.get_sim_hot_item_reall_filter))
         t.append(gevent.spawn(pool_recall.get_sim_hot_item_reall_filter))
-        t.append(gevent.spawn(pool_recall.recall_strategy_trend_v1, 'rv2:'))
+        t.append(gevent.spawn(pool_recall.get_return_video_reall, 'rv2:'))
         # todo:zhangbo
         # todo:zhangbo
         t.append(gevent.spawn(pool_recall.recall_strategy_trend_v1))
         t.append(gevent.spawn(pool_recall.recall_strategy_trend_v1))
 
 
@@ -670,7 +670,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
     if ab_code == 60098:
     if ab_code == 60098:
         rov_pool_recall = []
         rov_pool_recall = []
         if len(recall_result_list) >= 2:
         if len(recall_result_list) >= 2:
-            region_recall = recall_result_list[0]
+            region_recall = []#recall_result_list[0]
             return_video_reall = []
             return_video_reall = []
             sim_recall = []
             sim_recall = []
             trend_recall = []
             trend_recall = []

+ 1 - 0
video_recall.py

@@ -3967,6 +3967,7 @@ class PoolRecall(object):
                                videos_with_risk=self.videos_with_risk
                                videos_with_risk=self.videos_with_risk
                                )
                                )
         region_code = self.get_region_code()
         region_code = self.get_region_code()
+        print("zb" + str(data_for_filter))
         t = [gevent.spawn(filter_.filter_videos_for_group, region_code, videos) for videos in data_for_filter]
         t = [gevent.spawn(filter_.filter_videos_for_group, region_code, videos) for videos in data_for_filter]
         gevent.joinall(t)
         gevent.joinall(t)
         result_list = [i.get() for i in t if i.get() is not None and len(i.get()) > 0]
         result_list = [i.get() for i in t if i.get() is not None and len(i.get()) > 0]