'Update cluster state given a failed MetadataRequest.'

def failed_update(self, exception):

    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)
