From 8942fca788ba2c10d212eb349d6af21675fbabc3 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Wed, 15 Nov 2023 15:55:27 -0500 Subject: [PATCH] make it to 32 --- flow/connectors/snowflake/snowflake.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go index b2065a39c1..9e929c22de 100644 --- 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