|
def refresh(self, connection, timeout, target_type=None, change_type=None, fetch_size=None, |
|
metadata_request_timeout=None, **kwargs): |
|
|
|
server_version = self.get_host(connection.original_endpoint).release_version |
It is relevant for cases when metadata is pulled when control connection is reconnected.