diff --git a/dbt/adapters/snowflake.py b/dbt/adapters/snowflake.py
index 801628e2dbc..431f1b1c33f 100644
--- 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):