                                     normalize_method=normalization)
          self.save_queue = queue_manager.get_queue("extract_save")
          self.verify_output = False
          self.save_interval = None
          if hasattr(self.args, "save_interval"):
              self.save_interval = self.args.save_interval
          logger.debug("Initialized %s", self.__class__.__name__)
 
</s> remove 
 </s> add                 self.check_thread_error() </s> remove         return io_thread
 </s> add         self.threads.append(io_thread) </s> remove         save_thread.join()
 </s> add         for thread in self.threads:
            thread.join() </s> remove         save_thread = self.threaded_io("save")
 </s> add         self.threaded_io("save")
        self.threads = list()
                                     normalize_method=normalization)
          self.save_queue = queue_manager.get_queue("extract_save")
        self.threads = list()
          self.verify_output = False
          self.save_interval = None
          if hasattr(self.args, "save_interval"):
              self.save_interval = self.args.save_interval
          logger.debug("Initialized %s", self.__class__.__name__)
keep add keep keep keep keep keep
 Bugfix: Catch load/save errors and raise during extract 
scripts/extract.py