|
|
@@ -64,6 +64,10 @@ def filter_flow_pool():
|
|
|
else:
|
|
|
mapping[video_id].append(flow_pool)
|
|
|
# 过滤
|
|
|
+ if len(video_ids) == 0:
|
|
|
+ log_.info("data size = {}, video_ids size = {}, data = {}".format(len(data), len(video_ids), data))
|
|
|
+ log_.info("app_type {} videos filter end!".format(app_type))
|
|
|
+ continue
|
|
|
filtered_result = filter_video_status(video_ids=video_ids)
|
|
|
# 求差集，获取需要过滤掉的视频，并从redis中移除
|
|
|
filter_videos = set(video_ids) - set(filtered_result)
|
