|
@@ -548,9 +548,6 @@ class PoolRecall(object):
|
|
|
'executeTime': (time.time() - start_time) * 1000
|
|
'executeTime': (time.time() - start_time) * 1000
|
|
|
})
|
|
})
|
|
|
|
|
|
|
|
- # debug测试
|
|
|
|
|
- flow_pool_recall_result = []
|
|
|
|
|
-
|
|
|
|
|
return flow_pool_recall_result[:size]
|
|
return flow_pool_recall_result[:size]
|
|
|
|
|
|
|
|
def check_video_counts(self, video_ids, flow_pool_mapping):
|
|
def check_video_counts(self, video_ids, flow_pool_mapping):
|
|
@@ -1276,9 +1273,6 @@ class PoolRecall(object):
|
|
|
else:
|
|
else:
|
|
|
continue
|
|
continue
|
|
|
|
|
|
|
|
- # debug测试
|
|
|
|
|
- recall_result = []
|
|
|
|
|
-
|
|
|
|
|
# 130实验组不获取大列表的数据
|
|
# 130实验组不获取大列表的数据
|
|
|
if self.ab_code != config_.AB_CODE['region_rank_by_h'].get('abtest_130'):
|
|
if self.ab_code != config_.AB_CODE['region_rank_by_h'].get('abtest_130'):
|
|
|
# 判断获取到的小时级数据数量
|
|
# 判断获取到的小时级数据数量
|
