diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go index 59a345923b..59ace6d19f 100644 --- a/flow/connectors/snowflake/snowflake.go +++ b/flow/connectors/snowflake/snowflake.go @@ -138,7 +138,7 @@ func NewSnowflakeConnector(ctx context.Context, Database: snowflakeProtoConfig.Database, Warehouse: snowflakeProtoConfig.Warehouse, Role: snowflakeProtoConfig.Role, - RequestTimeout: time.Duration(snowflakeProtoConfig.QueryTimeout * 10), + RequestTimeout: time.Duration(snowflakeProtoConfig.QueryTimeout), DisableTelemetry: true, } snowflakeConfigDSN, err := gosnowflake.DSN(&snowflakeConfig)