make it to 32

PeerDB-io · Nov 15, 2023 · 8942fca · 8942fca
1 parent d0b4f20
commit 8942fca
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go
@@ -742,7 +742,7 @@ func (c *SnowflakeConnector) NormalizeRecords(req *model.NormalizeRecordsRequest
 
 	var totalRowsAffected int64 = 0
 	g, gCtx := errgroup.WithContext(c.ctx)
-	g.SetLimit(8) // limit parallel merges to 8
+	g.SetLimit(32) // limit parallel merges to 32
 
 	for _, destinationTableName := range destinationTableNames {
 		tableName := destinationTableName // local variable for the closure