Fixed typo
This commit is contained in:
@@ -3355,7 +3355,7 @@ class ResponseFuture(object):
|
|||||||
errors = self._errors
|
errors = self._errors
|
||||||
if not errors:
|
if not errors:
|
||||||
if self.is_schema_agreed:
|
if self.is_schema_agreed:
|
||||||
key = self._current_host.address if self.current_host else 'no host queried before timeout'
|
key = self._current_host.address if self._current_host else 'no host queried before timeout'
|
||||||
errors = {key: "Client request timeout. See Session.execute[_async](timeout)"}
|
errors = {key: "Client request timeout. See Session.execute[_async](timeout)"}
|
||||||
else:
|
else:
|
||||||
connection = self.session.cluster.control_connection._connection
|
connection = self.session.cluster.control_connection._connection
|
||||||
|
|||||||
Reference in New Issue
Block a user