docs: def _run(self):
          """Run method that can be profiled"""
          self.set_state(self.STATE_INITIALIZING)
          self.ioloop = ioloop.IOLoop.current()
          self.consumer_lock = locks.Lock()
  
          self.sentry_client = self.setup_sentry(
              self._kwargs['config'], self.consumer_name)
  
          try:
              self.setup()
          except (AttributeError, ImportError):
              return self.on_startup_error(
                  'Failed to import the Python module for {}'.format(
                      self.consumer_name))
  
          if not self.is_stopped:
              try:
                  self.ioloop.start()
              except KeyboardInterrupt:
                  LOGGER.warning('CTRL-C while waiting for clean shutdown')