From fd0ca7abada5a90aaf32c7470781edff808db2ea Mon Sep 17 00:00:00 2001 From: Ilias Xenogiannis Date: Thu, 14 Nov 2024 12:46:20 +0200 Subject: [PATCH] Update snowplow_normalize_base_events_this_run.sql --- models/base/scratch/snowplow_normalize_base_events_this_run.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/models/base/scratch/snowplow_normalize_base_events_this_run.sql b/models/base/scratch/snowplow_normalize_base_events_this_run.sql index 1dc353c..966ebd5 100644 --- a/models/base/scratch/snowplow_normalize_base_events_this_run.sql +++ b/models/base/scratch/snowplow_normalize_base_events_this_run.sql @@ -38,7 +38,7 @@ with prep AS ( and a.derived_tstamp <= {{ upper_limit }} {% endif %} and {{ snowplow_utils.app_id_filter(var("snowplow__app_id",[])) }} - -- We are doing the branching in order not to do the qualify in the case of spark, as it does not support it + {# We are doing the branching in order not to do the qualify in the case of spark, as it does not support it #} {% if target.type in ['databricks','snowflake','bigquery'] %} qualify row_number() over (partition by a.event_id order by a.collector_tstamp{% if target.type in ['databricks', 'spark'] -%}, a.etl_tstamp {%- endif %}) = 1 {% endif %}