Merge pull request #1398 from fishtown-analytics/feature/archive-no-c…

…reate-existing-schema

archives: do not create existing schema (#758)

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,

plugins/bigquery/dbt/adapters/bigquery/impl.py

@@ -75,6 +75,7 @@ def rename_relation(self, from_relation, to_relation):
             '`rename_relation` is not implemented for this adapter!'
         )
 
+    @available
     def list_schemas(self, database):
         conn = self.connections.get_thread_connection()
         client = conn.handle
@@ -84,6 +85,11 @@ def list_schemas(self, database):
                                                 include_all=True)
             return [ds.dataset_id for ds in all_datasets]
 
+    @available
+    def check_schema_exists(self, database, schema):
+        superself = super(BigQueryAdapter, self)
+        return superself.check_schema_exists(database, schema)
+
     def get_columns_in_relation(self, relation):
         try:
             table = self.connections.get_bq_table(

plugins/bigquery/dbt/include/bigquery/macros/adapters.sql

@@ -67,3 +67,13 @@
 {% macro bigquery__current_timestamp() -%}
   CURRENT_TIMESTAMP()
 {%- endmacro %}
+
+
+{% macro bigquery__list_schemas(database) %}
+  {{ return(adapter.list_schemas()) }}
+{% endmacro %}
+
+
+{% macro bigquery__check_schema_exists(information_schema, schema) %}
+  {{ return(adapter.check_schema_exists(information_schema.database, schema)) }}
+{% endmacro %}