|
@@ -364,8 +364,10 @@ class PoolRecall(object):
|
|
|
rov_pool_recall_result.extend(temp_result)
|
|
|
else:
|
|
|
# 将此次获取的末位视频id同步刷新到Redis中,方便下次快速定位到召回位置,过期时间为1天
|
|
|
- self.redis_helper.set_data_to_redis(key_name=last_rov_recall_key, value=data[-1][0],
|
|
|
- expire_time=expire_time)
|
|
|
+ if self.mid:
|
|
|
+ # mid为空时,不做记录
|
|
|
+ self.redis_helper.set_data_to_redis(key_name=last_rov_recall_key, value=data[-1][0],
|
|
|
+ expire_time=expire_time)
|
|
|
idx += get_size
|
|
|
|
|
|
# 生效中的置顶视频、被修改rov视频、rov召回池视频 归并排序
|
|
@@ -1172,8 +1174,10 @@ class PoolRecall(object):
|
|
|
recall_result.extend(temp_result)
|
|
|
else:
|
|
|
# 将此次获取的末位视频id同步刷新到Redis中,方便下次快速定位到召回位置,过期时间为1天
|
|
|
- self.redis_helper.set_data_to_redis(key_name=last_region_dup_key, value=data[-1][0],
|
|
|
- expire_time=expire_time)
|
|
|
+ if self.mid:
|
|
|
+ # mid为空时,不做记录
|
|
|
+ self.redis_helper.set_data_to_redis(key_name=last_region_dup_key, value=data[-1][0],
|
|
|
+ expire_time=expire_time)
|
|
|
idx += get_size
|
|
|
|
|
|
return recall_result[:size]
|