From 4816d69a4a9cd1cc570b97e6970dc9f37d2383cb Mon Sep 17 00:00:00 2001
From: Sergey Burykin <sburykin@ksense.io>
Date: Fri, 18 Sep 2020 18:39:26 +0300
Subject: [PATCH] fixed using warehouse from config

---
 adapters/snowflake.go | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git a/adapters/snowflake.go b/adapters/snowflake.go
index 82ba87f96..50dc5d42e 100644
--- a/adapters/snowflake.go
+++ b/adapters/snowflake.go
@@ -90,13 +90,14 @@ type Snowflake struct {
 //NewSnowflake return configured Snowflake adapter instance
 func NewSnowflake(ctx context.Context, config *SnowflakeConfig, s3Config *S3Config) (*Snowflake, error) {
 	cfg := &sf.Config{
-		Account:  config.Account,
-		User:     config.Username,
-		Password: config.Password,
-		Port:     config.Port,
-		Schema:   config.Schema,
-		Database: config.Db,
-		Params:   config.Parameters,
+		Account:   config.Account,
+		User:      config.Username,
+		Password:  config.Password,
+		Port:      config.Port,
+		Schema:    config.Schema,
+		Database:  config.Db,
+		Warehouse: config.Warehouse,
+		Params:    config.Parameters,
 	}
 	connectionString, err := sf.DSN(cfg)
 	if err != nil {