|
@@ -175,7 +175,7 @@ class FilterVideos(object):
|
|
|
filtered_videos = [video_id for video_id in video_ids if video_id not in filter_videos]
|
|
|
return filtered_videos
|
|
|
|
|
|
- def filter_videos_h(self, rule_key, ab_code, province_code, key_flag=''):
|
|
|
+ def filter_videos_h(self, rule_key, ab_code, province_code, key_flag='', pool_type='rov'):
|
|
|
"""召回小时级更新的视频过滤"""
|
|
|
# 预曝光过滤
|
|
|
st_pre = time.time()
|
|
@@ -221,6 +221,7 @@ class FilterVideos(object):
|
|
|
# et_viewed = time.time()
|
|
|
log_.info({
|
|
|
'logTimestamp': int(time.time() * 1000),
|
|
|
+ 'pool_type': pool_type,
|
|
|
'request_id': self.request_id,
|
|
|
'app_type': self.app_type,
|
|
|
'mid': self.mid,
|