Merge pull request #79 from dbt-labs/sessionization-incremental-dispa…

…tched Dispatch sessionization incremental filter
dbt-labs · Feb 25, 2022 · 5f4c0cf · 5f4c0cf
2 parents 466ba69 + df3b202
commit 5f4c0cf
Showing 1 changed file with 21 additions and 19 deletions.
diff --git a/macros/dbt_segment_utils.sql → ...ate_sessionization_incremental_filter.sql b/macros/dbt_segment_utils.sql → ...ate_sessionization_incremental_filter.sql
@@ -1,37 +1,39 @@
 {% macro generate_sessionization_incremental_filter(merge_target, filter_tstamp, max_tstamp) %}
+    {{ return(adapter.dispatch('generate_sessionization_incremental_filter', 'segment') (merge_target, filter_tstamp, max_tstamp)) }}
+{% endmacro %}
 
-    {% if target.type == 'bigquery' %}
-        where {{ filter_tstamp }} >= (
-        select 
-            timestamp_sub(
-                max({{ max_tstamp }}), 
-                interval {{ var('segment_sessionization_trailing_window') }} hour
-                )
-        from {{ merge_target }} 
-        )
 
-    {% elif target.type == 'postgres' %}
-        where cast({{ filter_tstamp }} as timestamp) >= (
+{% macro default__generate_sessionization_incremental_filter(merge_target, filter_tstamp, max_tstamp) %}
+    where {{ filter_tstamp }} >= (
         select
             {{ dbt_utils.dateadd(
                 'hour',
                 -var('segment_sessionization_trailing_window'),
                 'max(' ~ max_tstamp ~ ')'
             ) }}
         from {{ merge_target }} 
-        )
+    )
+{%- endmacro -%}
 
-    {% else %}
-        where {{ filter_tstamp }} >= (
+{% macro bigquery__generate_sessionization_incremental_filter(merge_target, filter_tstamp, max_tstamp) %}
+    where {{ filter_tstamp }} >= (
+        select 
+            timestamp_sub(
+                max({{ max_tstamp }}), 
+                interval {{ var('segment_sessionization_trailing_window') }} hour
+                )
+        from {{ merge_target }} 
+    )
+{%- endmacro -%}
+
+{% macro postgres__generate_sessionization_incremental_filter(merge_target, filter_tstamp, max_tstamp) %}
+    where cast({{ filter_tstamp }} as timestamp) >= (
         select
             {{ dbt_utils.dateadd(
                 'hour',
                 -var('segment_sessionization_trailing_window'),
                 'max(' ~ max_tstamp ~ ')'
             ) }}
         from {{ merge_target }} 
-        )
-
-    {% endif %}
-
-{% endmacro %}
+    )
+{%- endmacro -%}