|
@@ -99,7 +99,8 @@ def filter_video_status(video_ids):
|
|
|
:return: filtered_videos
|
|
:return: filtered_videos
|
|
|
"""
|
|
"""
|
|
|
if len(video_ids) == 1:
|
|
if len(video_ids) == 1:
|
|
|
- sql = "SELECT video_id " \
|
|
|
|
|
|
|
+ sql = "set hg_experimental_enable_shard_pruning=off; " \
|
|
|
|
|
+ "SELECT video_id " \
|
|
|
"FROM {} " \
|
|
"FROM {} " \
|
|
|
"WHERE audit_status = 5 " \
|
|
"WHERE audit_status = 5 " \
|
|
|
"AND applet_rec_status IN (1, -6) " \
|
|
"AND applet_rec_status IN (1, -6) " \
|
|
@@ -109,7 +110,8 @@ def filter_video_status(video_ids):
|
|
|
"AND transcoding_status = 3 " \
|
|
"AND transcoding_status = 3 " \
|
|
|
"AND video_id IN ({});".format(config_.VIDEO_STATUS, video_ids[0])
|
|
"AND video_id IN ({});".format(config_.VIDEO_STATUS, video_ids[0])
|
|
|
else:
|
|
else:
|
|
|
- sql = "SELECT video_id " \
|
|
|
|
|
|
|
+ sql = "set hg_experimental_enable_shard_pruning=off; " \
|
|
|
|
|
+ "SELECT video_id " \
|
|
|
"FROM {} " \
|
|
"FROM {} " \
|
|
|
"WHERE audit_status = 5 " \
|
|
"WHERE audit_status = 5 " \
|
|
|
"AND applet_rec_status IN (1, -6) " \
|
|
"AND applet_rec_status IN (1, -6) " \
|
