File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change 22
22
from cassandra .query import (
23
23
UNSET_VALUE ,
24
24
SimpleStatement ,
25
- ValueSequence ,
26
25
dict_factory ,
27
26
named_tuple_factory , PreparedStatement ,
28
27
)
@@ -146,7 +145,6 @@ async def async_setup(self):
146
145
if self .dbid is None :
147
146
await self .get_or_create_db ()
148
147
149
- # Attempt to connect synchronously (assuming connect is a sync method)
150
148
session = self .connect ()
151
149
if session :
152
150
self .session : Session = session
@@ -337,7 +335,7 @@ def connect(self, retry=False) -> Session:
337
335
with open (bundlepath , "wb" ) as f :
338
336
f .write (r .content )
339
337
# Connect to the cluster
340
- cloud_config = {"secure_connect_bundle" : bundlepath }
338
+ cloud_config = {"secure_connect_bundle" : bundlepath , "connect_timeout" : 120 }
341
339
auth_provider = PlainTextAuthProvider (CASSANDRA_USER , token )
342
340
cluster = Cluster (
343
341
cloud = cloud_config ,
You can’t perform that action at this time.
0 commit comments