if the schema exists, do not try to create it

dbt-labs · Apr 23, 2019 · cc4f285 · cc4f285
1 parent 2efae5a
commit cc4f285
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 3 deletions.
diff --git a/core/dbt/include/global_project/macros/materializations/archive/archive.sql b/core/dbt/include/global_project/macros/materializations/archive/archive.sql
@@ -253,7 +253,14 @@
   {%- set target_table = model.get('alias', model.get('name')) -%}
   {%- set strategy = config.get('strategy') -%}
 
-  {{ create_schema(target_database, target_schema) }}
+  {% set information_schema = api.Relation.create(
+    database=target_database,
+    schema=target_schema,
+    identifier=target_table).information_schema() %}
+
+  {% if not check_schema_exists(information_schema, target_schema) %}
+    {{ create_schema(target_database, target_schema) }}
+  {% endif %}
 
   {%- set target_relation = adapter.get_relation(
       database=target_database,

diff --git a/plugins/bigquery/dbt/include/bigquery/macros/adapters.sql b/plugins/bigquery/dbt/include/bigquery/macros/adapters.sql
@@ -74,6 +74,6 @@
 {% endmacro %}
 
 
-{% macro bigquery__check_schema_exists(database, schema) %}
-  {{ return(adapter.check_schema_exists(database, schema)) }}
+{% macro bigquery__check_schema_exists(information_schema, schema) %}
+  {{ return(adapter.check_schema_exists(information_schema.database, schema)) }}
 {% endmacro %}