docs: def flush(self):
          """Ensure all logging output has been flushed."""
          if self.shutdown:
              return
          self.flush_buffers(force=True)
          self.queue.put(FLUSH_MARKER)
          self.queue.join()