casds: More lax timeouts

filecoin-project · Apr 5, 2023 · f0ec716 · f0ec716
1 parent 18a9aad
commit f0ec716
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/blockstore/cassbs/cassandra_ds.go b/blockstore/cassbs/cassandra_ds.go
@@ -26,6 +26,9 @@ func NewCassandraDS(connectString string) (*CassandraDatastore, error) {
 	cluster := gocql.NewCluster(connectString)
 	cluster.Consistency = gocql.Quorum
 	cluster.RetryPolicy = &gocql.SimpleRetryPolicy{NumRetries: 30}
+	cluster.Timeout = 30 * time.Second
+	cluster.ConnectTimeout = 30 * time.Second
+
 	session, err := cluster.CreateSession()
 	if err != nil {
 		return nil, fmt.Errorf("creating new Cassandra session: %w", err)