|
@@ -131,8 +131,7 @@ class PoolRecall(object):
|
|
|
ge = gevent.spawn(self.check_video_counts, video_ids=filtered_result, flow_pool_mapping=video_mapping)
|
|
|
ge.join()
|
|
|
check_result = ge.get()
|
|
|
- #check_result, error_flag = self.check_video_counts(video_ids=filtered_result,
|
|
|
- flow_pool_mapping=video_mapping)
|
|
|
+ #check_result, error_flag = self.check_video_counts(video_ids=filtered_result, flow_pool_mapping=video_mapping)
|
|
|
# 判断错误标记, True为错误
|
|
|
if error_flag:
|
|
|
# 结束流量池召回
|