From 5554279b4fb74db460078187b558fdd8bffa0fe8 Mon Sep 17 00:00:00 2001 From: Tristan Handy Date: Mon, 7 Aug 2017 15:53:25 -0400 Subject: [PATCH] namespaced all already_exists calls --- models/identification/snowplow_id_map.sql | 2 +- models/page_views/snowplow_page_views.sql | 2 +- models/page_views/snowplow_web_events.sql | 3 +-- models/page_views/snowplow_web_events_scroll_depth.sql | 2 +- models/page_views/snowplow_web_events_time.sql | 2 +- 5 files changed, 5 insertions(+), 6 deletions(-) diff --git a/models/identification/snowplow_id_map.sql b/models/identification/snowplow_id_map.sql index c61c18e..068177f 100644 --- 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 index 1dac4d4..7132a00 100644 --- 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 index 0530862..9576b41 100644 --- 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 index 5b9552b..a0ba0c8 100644 --- 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 index 0cb269a..374194e 100644 --- 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 (