@@ -534,6 +534,7 @@ def update_local_distribute_count(videos):
]
for key in video_flow_pool_key_list:
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):
# # 该视频本地有记录，本地记录的分发数 - 1
