@@ -1015,7 +1015,7 @@ def default_retry_policy(self, policy):
1015
1015
cloud = None
1016
1016
"""
1017
1017
A dict of the cloud configuration. Example::
1018
-
1018
+
1019
1019
{
1020
1020
# path to the secure connect bundle
1021
1021
'secure_connect_bundle': '/path/to/secure-connect-dbname.zip',
@@ -1779,7 +1779,7 @@ def connect(self, keyspace=None, wait_for_all_pools=False):
1779
1779
self .contact_points , self .protocol_version )
1780
1780
self .connection_class .initialize_reactor ()
1781
1781
_register_cluster_shutdown (self )
1782
-
1782
+
1783
1783
self ._add_resolved_hosts ()
1784
1784
1785
1785
try :
@@ -3628,7 +3628,7 @@ def _set_new_connection(self, conn):
3628
3628
if old :
3629
3629
log .debug ("[control connection] Closing old connection %r, replacing with %r" , old , conn )
3630
3630
old .close ()
3631
-
3631
+
3632
3632
def _connect_host_in_lbp (self ):
3633
3633
errors = {}
3634
3634
lbp = (
@@ -3649,7 +3649,7 @@ def _connect_host_in_lbp(self):
3649
3649
log .warning ("[control connection] Error connecting to %s:" , host , exc_info = True )
3650
3650
if self ._is_shutdown :
3651
3651
raise DriverException ("[control connection] Reconnection in progress during shutdown" )
3652
-
3652
+
3653
3653
return (None , errors )
3654
3654
3655
3655
def _reconnect_internal (self ):
@@ -3673,7 +3673,7 @@ def _reconnect_internal(self):
3673
3673
(conn , errors ) = self ._connect_host_in_lbp ()
3674
3674
if conn is not None :
3675
3675
return conn
3676
-
3676
+
3677
3677
raise NoHostAvailable ("Unable to connect to any servers" , errors )
3678
3678
3679
3679
def _try_connect (self , host ):
0 commit comments