docs: def run(self):
          """ Run the pipeline queue.
  
          The pipeline queue will run forever.
          """
          while True:
              self._event.clear()
              self._queue.get().run(self._event)