code: def flush(self):
          
          self.logger.debug('Flush joining')
          self.queue.join()
          self.logger.debug('Flush joining ready')
docs: This only needs to be called manually
          from unit tests