Fix _connection attribute access

aboudreault · aboudreault · commit d6b7ddfdd0c8 · 2016-06-09T17:35:59.000-04:00
diff --git a/cassandra/cluster.py b/cassandra/cluster.py
@@ -1364,7 +1364,7 @@ def get_control_connection_host(self):
         """
         Returns the control connection host metadata.
         """
-        connection = getattr(self.control_connection, '_connection')
+        connection = self.control_connection._connection
         host = connection.host if connection else None
         return self.metadata.get_host(host) if host else None
 
@@ -2913,7 +2913,7 @@ def _on_timeout(self):
             if self.is_schema_agreed:
                 errors = {self._current_host.address: "Client request timeout. See Session.execute[_async](timeout)"}
             else:
-                connection = getattr(self.session.cluster.control_connection, '_connection')
+                connection = self.session.cluster.control_connection._connection
                 host = connection.host if connection else 'unknown'
                 errors = {host: "Request timed out while waiting for schema agreement. See Session.execute[_async](timeout) and Cluster.max_schema_agreement_wait."}
 
