docs: def run(self, stop):
          """ Run the pipeline.
  
          :param stop: Stop event
          """
          _LOGGER.info("Starting a new pipeline on group %s", self._group)
          self._group.bridge.incr_active()
          for i, stage in enumerate(self._pipe):
              self._execute_stage(i, stage, stop)
          _LOGGER.info("Finished pipeline on group %s", self._group)
          self._group.bridge.decr_active()