|
@@ -305,10 +305,11 @@ def update_redis_data(result, app_type, mid, last_rov_recall_key, top_K, expire_
|
|
|
log_.info('last video redis update success!')
|
|
|
|
|
|
# 将此次分发的流量池视频,对 本地分发数-1 进行记录
|
|
|
- flow_recall_video = [item for item in result if item['pushFrom'] == config_.PUSH_FROM['flow_recall']]
|
|
|
- if flow_recall_video:
|
|
|
- update_local_distribute_count(flow_recall_video)
|
|
|
- log_.info('update local distribute count success!')
|
|
|
+ if app_type not in [config_.APP_TYPE['LAO_HAO_KAN_VIDEO'], config_.APP_TYPE['ZUI_JING_QI']]:
|
|
|
+ flow_recall_video = [item for item in result if item['pushFrom'] == config_.PUSH_FROM['flow_recall']]
|
|
|
+ if flow_recall_video:
|
|
|
+ update_local_distribute_count(flow_recall_video)
|
|
|
+ log_.info('update local distribute count success!')
|
|
|
|
|
|
except Exception as e:
|
|
|
log_.error("update redis data fail!")
|