open flow pool recall

video_recall.py

@@ -84,9 +84,6 @@ class PoolRecall(object):
 
     def flow_pool_recall(self, size=10):
         """从流量池中获取视频"""
-        # 暂时关闭流量池召回
-        return []
-        """
         log_.info('====== flow pool recall')
         flow_pool_key = self.get_pool_redis_key('flow')
         flow_pool_recall_result = []
@@ -162,7 +159,6 @@ class PoolRecall(object):
             idx += get_size
 
         return flow_pool_recall_result[:size]
-        """
 
     def check_video_counts(self, video_ids, flow_pool_mapping):
         """