update sim recall

recommend.py

@@ -372,9 +372,7 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
 
     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 == 60052:
-            t.append(pool_recall.get_title_recall)
-        elif ab_code ==60053:
+        if ab_code ==60053:
             t.append(pool_recall.get_sim_hot_item_reall_filter)
         elif ab_code == 60055:
             t.append(gevent.spawn(pool_recall.get_3days_hot_item_reall))
@@ -384,9 +382,10 @@ def video_old_recommend(request_id, mid, uid, size, top_K, flow_pool_P, app_type
         t = [gevent.spawn(pool_recall.rov_pool_recall_with_region, size, expire_time),
              gevent.spawn(pool_recall.flow_pool_recall, size, config_.QUICK_FLOW_POOL_ID),
              gevent.spawn(pool_recall.flow_pool_recall, size)]
-        if ab_code == 60052:
-            t.append(pool_recall.get_title_recall)
-        elif  ab_code == 60053:
+        # if ab_code == 60052:
+        #     t.append(pool_recall.get_title_recall)
+        # el
+        if  ab_code == 60053:
             t.append(pool_recall.get_sim_hot_item_reall_filter)
         elif ab_code == 60055:
             t.append(gevent.spawn(pool_recall.get_3days_hot_item_reall))

video_rank.py

@@ -608,10 +608,8 @@ def video_new_rank2(data, size, top_K, flow_pool_P, ab_code):
     vidKeys = []
     recall_list = []
     pre_str = "k_p2:"
-    if ab_code == 60053:
+    if ab_code == 60053 or ab_code == 60052 :
         pre_str = "k_p2:"
-    elif ab_code == 60052:
-        pre_str = "k_p:"
     elif ab_code == 60054:
         pre_str = "k_p3:"
     elif ab_code == 60055:

video_recall.py

@@ -2160,7 +2160,7 @@ class PoolRecall(object):
         for vid in filtered_viewed_videos:
             if vid in recall_dict:
                 recall_result.append(recall_dict[vid])
-        return recall_result
+        return recall_result[:30]
     # get region_hour_recall
     def get_region_hour_recall(self, size=4, region_code='-1'):
         pool_key_prefix = config_.RECALL_KEY_NAME_PREFIX_REGION_BY_H
@@ -2178,7 +2178,7 @@ class PoolRecall(object):
                      'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['rov_recall_region_h'],
                      'abCode': self.ab_code}
                 )
-        return recall_result[:200]
+        return recall_result[:30]
 
     # get region_day_recall
     def get_region_day_recall(self, size=4,region_code='-1'):