From d7a7ca072ee11219ca1b154f13d36c6617b85663 Mon Sep 17 00:00:00 2001 From: Kunal Gupta <39487888+iamKunalGupta@users.noreply.github.com> Date: Thu, 21 Mar 2024 02:28:05 +0530 Subject: [PATCH] fix(snowflake): use s3 csc staging path --- 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 746768bf51..b1877320e1 100644 --- a/flow/connectors/snowflake/snowflake.go +++ b/flow/connectors/snowflake/snowflake.go @@ -459,7 +459,7 @@ func (c *SnowflakeConnector) syncRecordsViaAvro( } qrepConfig := &protos.QRepConfig{ - StagingPath: "", + StagingPath: req.StagingPath, FlowJobName: req.FlowJobName, DestinationTableIdentifier: strings.ToLower(fmt.Sprintf("%s.%s", c.rawSchema, rawTableIdentifier)),