Do case-insensitive schema comparisons to test for schema existance

dbt-labs · Aug 5, 2019 · f03f9cc · f03f9cc
1 parent b2f2e69
commit f03f9cc
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/core/dbt/task/runnable.py b/core/dbt/task/runnable.py
@@ -320,7 +320,12 @@ def create_schemas(self, adapter, selected_uids):
         for db in required_databases:
             existing_schemas.update((db, s) for s in adapter.list_schemas(db))
 
-        for database, schema in (required_schemas - existing_schemas):
+        lower_tuple = lambda t: tuple(map(str.lower, t))
+
+        required_schemas_lowered = set(map(lower_tuple, required_schemas))
+        existing_schemas_lowered = set(map(lower_tuple, existing_schemas))
+
+        for database, schema in (required_schemas_lowered - existing_schemas_lowered):
             adapter.create_schema(database, schema)
 
     def get_result(self, results, elapsed_time, generated_at):