|
@@ -534,6 +534,7 @@ def update_local_distribute_count(videos):
|
|
|
]
|
|
]
|
|
|
for key in video_flow_pool_key_list:
|
|
for key in video_flow_pool_key_list:
|
|
|
redis_helper.remove_value_from_set(key_name=key, values=(flow_pool, ))
|
|
redis_helper.remove_value_from_set(key_name=key, values=(flow_pool, ))
|
|
|
|
|
+ log_.info({'tag': 'remove video_id from flow_pool', 'video_id': video_id, 'flow_pool': flow_pool})
|
|
|
|
|
|
|
|
# if redis_helper.key_exists(key_name=key_name):
|
|
# if redis_helper.key_exists(key_name=key_name):
|
|
|
# # 该视频本地有记录，本地记录的分发数 - 1
|
|
# # 该视频本地有记录，本地记录的分发数 - 1
|
