Fixes already opened transaction issue

For #602
dbt-labs · Dec 14, 2017 · 95b2a16 · 95b2a16
1 parent 6dbe79b
commit 95b2a16
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/dbt/adapters/snowflake.py b/dbt/adapters/snowflake.py
@@ -147,7 +147,11 @@ def add_begin_query(cls, profile, name):
     def create_schema(cls, profile, schema, model_name=None):
         logger.debug('Creating schema "%s".', schema)
         sql = cls.get_create_schema_sql(schema)
-        return cls.add_query(profile, sql, model_name, select_schema=False)
+        res = cls.add_query(profile, sql, model_name, select_schema=False)
+
+        cls.commit_if_has_connection(profile, model_name)
+
+        return res
 
     @classmethod
     def get_existing_schemas(cls, profile, model_name=None):