ADD:log
Showing
1 changed file
with
2 additions
and
1 deletions
... | @@ -1694,11 +1694,12 @@ class Command(BaseCommand, LoggerMixin): | ... | @@ -1694,11 +1694,12 @@ class Command(BaseCommand, LoggerMixin): |
1694 | self.log_base, img_path, traceback.format_exc())) | 1694 | self.log_base, img_path, traceback.format_exc())) |
1695 | 1695 | ||
1696 | def res_2_wb(self, res_dict, img_queue, finish_queue, error_list): | 1696 | def res_2_wb(self, res_dict, img_queue, finish_queue, error_list): |
1697 | self.online_log.info('{0} [res_2_wb] [get task] [queue running] [finish_queue_size={1}]'.format(self.log_base, finish_queue.qsize())) | ||
1697 | while len(error_list) == 0 or not img_queue.empty() or not finish_queue.empty(): | 1698 | while len(error_list) == 0 or not img_queue.empty() or not finish_queue.empty(): |
1698 | try: | 1699 | try: |
1699 | task_str = finish_queue.get(block=False) | 1700 | task_str = finish_queue.get(block=False) |
1700 | except Exception as e: | 1701 | except Exception as e: |
1701 | # self.online_log.info('{0} [res_2_wb] [queue empty]'.format(self.log_base)) | 1702 | self.online_log.info('{0} [res_2_wb] [queue empty]'.format(self.log_base)) |
1702 | time.sleep(self.sleep_time_task_get) | 1703 | time.sleep(self.sleep_time_task_get) |
1703 | continue | 1704 | continue |
1704 | else: | 1705 | else: | ... | ... |
-
Please register or sign in to post a comment