updated macro to solve issue (#19)

Adjustment to updated return_limits_from_model macro
snowplow · Oct 11, 2024 · 5325a67 · 5325a67
1 parent 0dfe0f2
commit 5325a67
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/macros/attribution_overview.sql b/macros/attribution_overview.sql
@@ -12,7 +12,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
 
 {% macro default__attribution_overview() %}
 
-{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(ref('snowplow_attribution_campaign_attributions'),'cv_tstamp','cv_tstamp') %}
+{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(ref('snowplow_attribution_campaign_attributions'),'cv_tstamp','cv_tstamp',true) %}
 
 -- making sure we only include spend that is needed
 with spend_with_unique_keys as (

diff --git a/macros/paths_to_conversion.sql b/macros/paths_to_conversion.sql
@@ -19,7 +19,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
 
 {% macro default__paths_to_conversion() %}
 
-{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(this,'cv_path_start_tstamp','cv_path_start_tstamp') %}
+{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(this,'cv_path_start_tstamp','cv_path_start_tstamp',true) %}
 
   with paths as (
 

diff --git a/macros/source_checks.sql b/macros/source_checks.sql
@@ -8,9 +8,9 @@
 
   {% set conversions_source_relation = snowplow_attribution.get_relation_from_string(var('snowplow__conversions_source', '')) | default(source('derived', 'snowplow_unified_conversions')) %}
   {% set conversion_path_source_relation = snowplow_attribution.get_relation_from_string(var('snowplow__conversion_path_source', '')) | default(source('derived', 'snowplow_unified_views')) %}
-  {%- set __, last_cv_tstamp = snowplow_utils.return_limits_from_model(conversions_source_relation,'cv_tstamp','cv_tstamp') %}
-  {%- set __, last_path_tstamp = snowplow_utils.return_limits_from_model(conversion_path_source_relation,'start_tstamp','start_tstamp') %}
-  {%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(this,'cv_path_start_tstamp','cv_path_start_tstamp') %}
+  {%- set __, last_cv_tstamp = snowplow_utils.return_limits_from_model(conversions_source_relation,'cv_tstamp','cv_tstamp',true) %}
+  {%- set __, last_path_tstamp = snowplow_utils.return_limits_from_model(conversion_path_source_relation,'start_tstamp','start_tstamp',true) %}
+  {%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(this,'cv_path_start_tstamp','cv_path_start_tstamp',true) %}
 
   {% if is_incremental() %}
     {% if last_cv_tstamp < last_processed_cv_tstamp %}

diff --git a/models/snowplow_attribution_campaign_attributions.sql b/models/snowplow_attribution_campaign_attributions.sql
@@ -29,7 +29,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
   )
 }}
 
-{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(ref('snowplow_attribution_incremental_manifest'),'last_processed_cv_tstamp','last_processed_cv_tstamp') %}
+{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(ref('snowplow_attribution_incremental_manifest'),'last_processed_cv_tstamp','last_processed_cv_tstamp',true) %}
 
 
 with arrays as (

diff --git a/models/snowplow_attribution_channel_attributions.sql b/models/snowplow_attribution_channel_attributions.sql
@@ -28,8 +28,8 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
     snowplow_optimize = true
   )
 }}
+{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(ref('snowplow_attribution_incremental_manifest'),'last_processed_cv_tstamp','last_processed_cv_tstamp',true) %}
 
-{%- set __, last_processed_cv_tstamp = snowplow_utils.return_limits_from_model(ref('snowplow_attribution_incremental_manifest'),'last_processed_cv_tstamp','last_processed_cv_tstamp') %}
 
 with arrays as (