|
@@ -130,7 +130,7 @@ class PoolRecall(object):
|
|
|
st_check = time.time()
|
|
|
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 = ge.get()
|
|
|
#check_result, error_flag = self.check_video_counts(video_ids=filtered_result, flow_pool_mapping=video_mapping)
|
|
|
# 判断错误标记, True为错误
|
|
|
if error_flag:
|