code: def start(self):
          
          self.logger.debug("Starting partition service", extra=self._logger_extras)
  
          def partition_updater():
              self._do_refresh()
              self.timer = self._client.reactor.add_timer(PARTITION_UPDATE_INTERVAL, partition_updater)
  
          self.timer = self._client.reactor.add_timer(PARTITION_UPDATE_INTERVAL, partition_updater)
docs: Starts the partition service.