Skip to content

Commit

Permalink
Update snowplow_normalize_base_events_this_run.sql
Browse files Browse the repository at this point in the history
  • Loading branch information
ilias1111 committed Nov 14, 2024
1 parent ffff3fb commit fd0ca7a
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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 %}
Expand Down

0 comments on commit fd0ca7a

Please sign in to comment.