docs: def failed_update(self, exception):
          """Update cluster state given a failed MetadataRequest."""
          f = None
          with self._lock:
              if self._future:
                  f = self._future
                  self._future = None
          if f:
              f.failure(exception)
          self._last_refresh_ms = time.time() * 1000