Merge pull request #16 from fishtown-analytics/feature/upgrade-to-dbt…

…-090 namespaced all already_exists calls
dbt-labs · Aug 7, 2017 · 11f6f96 · 11f6f96
2 parents a280b73 + 5554279
commit 11f6f96
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 6 deletions.
diff --git a/models/identification/snowplow_id_map.sql b/models/identification/snowplow_id_map.sql
@@ -24,7 +24,7 @@ new_events as (
     select *
     from all_events
 
-    {% if already_exists(this.schema, this.name) and not flags.FULL_REFRESH %}
+    {% if adapter.already_exists(this.schema, this.name) and not flags.FULL_REFRESH %}
     where collector_tstamp > (
         select coalesce(max(max_tstamp), '0001-01-01') from {{ this }}
     )

diff --git a/models/page_views/snowplow_page_views.sql b/models/page_views/snowplow_page_views.sql
@@ -25,7 +25,7 @@ with all_events as (
 web_events as (
 
     select * from all_events
-    {% if already_exists(this.schema, this.name) and not flags.FULL_REFRESH %}
+    {% if adapter.already_exists(this.schema, this.name) and not flags.FULL_REFRESH %}
     where collector_tstamp > (
         select coalesce(max(max_tstamp), '0001-01-01') from {{ this }}
     )

diff --git a/models/page_views/snowplow_web_events.sql b/models/page_views/snowplow_web_events.sql
@@ -23,7 +23,7 @@ with all_events as (
 events as (
 
     select * from all_events
-    {% if already_exists(this.schema, this.name) and not flags.FULL_REFRESH %}
+    {% if adapter.already_exists(this.schema, this.name) and not flags.FULL_REFRESH %}
     where collector_tstamp > (
         select coalesce(max(collector_tstamp), '0001-01-01') from {{ this }}
     )
@@ -134,4 +134,3 @@ dedupe as (
 )
 
 select * from dedupe where n = 1
-
diff --git a/models/page_views/snowplow_web_events_scroll_depth.sql b/models/page_views/snowplow_web_events_scroll_depth.sql
@@ -10,7 +10,7 @@
 }}
 
 {# cache this because we need it below too #}
-{% set this_exists = already_exists(this.schema, this.name) and not flags.FULL_REFRESH%}
+{% set this_exists = adapter.already_exists(this.schema, this.name) and not flags.FULL_REFRESH%}
 
 with all_events as (
 

diff --git a/models/page_views/snowplow_web_events_time.sql b/models/page_views/snowplow_web_events_time.sql
@@ -10,7 +10,7 @@
 }}
 
 {# cache this because we need it below too #}
-{% set this_exists = already_exists(this.schema, this.name) and not flags.FULL_REFRESH%}
+{% set this_exists = adapter.already_exists(this.schema, this.name) and not flags.FULL_REFRESH%}
 
 with all_events as (