docs: def run(self):
          """Start the consumer"""
          if self.profile_file:
              LOGGER.info('Profiling to %s', self.profile_file)
              profile.runctx('self._run()', globals(), locals(),
                             self.profile_file)
          else:
              self._run()
          LOGGER.debug('Exiting %s (%i, %i)', self.name, os.getpid(),
                       os.getppid())