def start(self):
self.logger.debug("<STR_LIT>", extra=self._logger_extras)<EOL>def partition_updater():<EOL><INDENT>self._do_refresh()<EOL>self.timer = self._client.reactor.add_timer(PARTITION_UPDATE_INTERVAL, partition_updater)<EOL><DEDENT>self.timer = self._client.reactor.add_timer(PARTITION_UPDATE_INTERVAL, partition_updater)<EOL>
Starts the partition service.