diff --git a/flow/connectors/snowflake/snowflake.go b/flow/connectors/snowflake/snowflake.go index 7c00309098..93dd1a3fbb 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), + RequestTimeout: time.Duration(snowflakeProtoConfig.QueryTimeout * 10), DisableTelemetry: true, } snowflakeConfigDSN, err := gosnowflake.DSN(&snowflakeConfig)