Run the pipeline queue.

        The pipeline queue will run forever.

def run(self):
        """ Run the pipeline queue.

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