Skip to content

Commit

Permalink
Prefix all macro calls (Close #25)
Browse files Browse the repository at this point in the history
  • Loading branch information
@rlh1994
rlh1994 committed Feb 26, 2024
1 parent dd810db commit 416aad7
Show file tree
Hide file tree
Showing 44 changed files with 531 additions and 533 deletions.
10 changes: 5 additions & 5 deletions macros/field_definitions/conversion_query.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
,SUM(CASE WHEN {{ when_condition }} THEN coalesce({{ then_condition }}, {{ conv_object.get('default_value', 0) }}) ELSE 0 END) AS cv_{{ conv_object['name'] }}_total
{%- endif %}
,MIN(CASE WHEN {{ when_condition }} THEN {{ tstamp_field }} ELSE null END) AS cv_{{ conv_object['name'] }}_first_conversion
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ dbt.type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
{%- else -%}
,coalesce(cv_{{ conv_object['name'] }}_volume, 0) as cv_{{ conv_object['name'] }}_volume
{%- if conv_object.get('list_events', false) %}
Expand Down Expand Up @@ -63,7 +63,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
,SUM(CASE WHEN {{ when_condition }} THEN coalesce({{ then_condition }}, {{ conv_object.get('default_value', 0) }}) ELSE 0 END) AS cv_{{ conv_object['name'] }}_total
{%- endif -%}
,MIN(CASE WHEN {{ when_condition }} THEN {{ tstamp_field }} ELSE null END) AS cv_{{ conv_object['name'] }}_first_conversion
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ dbt.type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
{%- else -%}
,coalesce(cv_{{ conv_object['name'] }}_volume, 0) as cv_{{ conv_object['name'] }}_volume
{%- if conv_object.get('list_events', false) %}
Expand Down Expand Up @@ -97,7 +97,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
,SUM(CASE WHEN {{ when_condition }} THEN coalesce({{ then_condition }}, {{ conv_object.get('default_value', 0) }}) ELSE 0 END) AS cv_{{ conv_object['name'] }}_total
{%- endif -%}
,MIN(CASE WHEN {{ when_condition }} THEN {{ tstamp_field }} ELSE null END) AS cv_{{ conv_object['name'] }}_first_conversion
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ dbt.type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
{%- else -%}
,coalesce(cv_{{ conv_object['name'] }}_volume, 0) as cv_{{ conv_object['name'] }}_volume
{%- if conv_object.get('list_events', false) %}
Expand Down Expand Up @@ -128,7 +128,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
,SUM(CASE WHEN {{ when_condition }} THEN coalesce({{ then_condition }}, {{ conv_object.get('default_value', 0) }}) ELSE 0 END) AS cv_{{ conv_object['name'] }}_total
{%- endif -%}
,MIN(CASE WHEN {{ when_condition }} THEN {{ tstamp_field }} ELSE null END) AS cv_{{ conv_object['name'] }}_first_conversion
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ dbt.type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
{%- else -%}
,coalesce(cv_{{ conv_object['name'] }}_volume, 0) as cv_{{ conv_object['name'] }}_volume
{%- if conv_object.get('list_events', false) %}
Expand Down Expand Up @@ -160,7 +160,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
,SUM(CASE WHEN {{ when_condition }} THEN coalesce({{ then_condition }}, {{ conv_object.get('default_value', 0) }}) ELSE 0 END) AS cv_{{ conv_object['name'] }}_total
{%- endif -%}
,MIN(CASE WHEN {{ when_condition }} THEN {{ tstamp_field }} ELSE null END) AS cv_{{ conv_object['name'] }}_first_conversion
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
,CAST(MAX(CASE WHEN {{ when_condition }} THEN 1 ELSE 0 END) AS {{ dbt.type_boolean() }}) AS cv_{{ conv_object['name'] }}_converted
{%- else -%}
,coalesce(cv_{{ conv_object['name'] }}_volume, 0) as cv_{{ conv_object['name'] }}_volume
{%- if conv_object.get('list_events', false) %}
Expand Down
12 changes: 6 additions & 6 deletions macros/field_extractions/get_app_context_fields.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,8 +32,8 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
relation=source('atomic', 'events') if 'integration_tests' not in project_name and 'snowplow' not in project_name else ref('snowplow_unified_events_stg'),
relation_alias=none) }}
{% else %}
, cast(null as {{ type_string() }}) as app__build
, cast(null as {{ type_string() }}) as app__version
, cast(null as {{ dbt.type_string() }}) as app__build
, cast(null as {{ dbt.type_string() }}) as app__version
{% endif %}
{% endmacro %}

Expand All @@ -42,8 +42,8 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, contexts_com_snowplowanalytics_mobile_application_1[0].build::STRING AS app__build
, contexts_com_snowplowanalytics_mobile_application_1[0].version::STRING AS app__version
{% else %}
, cast(null as {{ type_string() }}) as app__build
, cast(null as {{ type_string() }}) as app__version
, cast(null as {{ dbt.type_string() }}) as app__build
, cast(null as {{ dbt.type_string() }}) as app__version
{% endif %}
{% endmacro %}

Expand All @@ -52,7 +52,7 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, contexts_com_snowplowanalytics_mobile_application_1[0]:build::varchar(255) AS app__build
, contexts_com_snowplowanalytics_mobile_application_1[0]:version::varchar(255) AS app__version
{% else %}
, cast(null as {{ type_string() }}) as app__build
, cast(null as {{ type_string() }}) as app__version
, cast(null as {{ dbt.type_string() }}) as app__build
, cast(null as {{ dbt.type_string() }}) as app__version
{% endif %}
{% endmacro %}
60 changes: 30 additions & 30 deletions macros/field_extractions/get_app_error_event_fields.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -16,10 +16,10 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, cast(null as {{ snowplow_utils.type_max_string() }}) as app_error__programming_language
, cast(null as {{ snowplow_utils.type_max_string() }}) as app_error__class_name
, cast(null as {{ snowplow_utils.type_max_string() }}) as app_error__exception_name
, cast(null as {{ type_boolean() }}) as app_error__is_fatal
, cast(null as {{ type_int() }}) as app_error__line_number
, cast(null as {{ dbt.type_boolean() }}) as app_error__is_fatal
, cast(null as {{ dbt.type_int() }}) as app_error__line_number
, cast(null as {{ snowplow_utils.type_max_string() }}) as app_error__stack_trace
, cast(null as {{ type_int() }}) as app_error__thread_id
, cast(null as {{ dbt.type_int() }}) as app_error__thread_id
, cast(null as {{ snowplow_utils.type_max_string() }}) as app_error__thread_name
{% endif %}
{% endmacro %}
Expand All @@ -46,15 +46,15 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
relation=source('atomic', 'events') if 'integration_tests' not in project_name and 'snowplow' not in project_name else ref('snowplow_unified_events_stg'),
relation_alias=none) }}
{% else %}
, cast(null as {{ type_string() }}) as app_error__message
, cast(null as {{ type_string() }}) as app_error__programming_language
, cast(null as {{ type_string() }}) as app_error__class_name
, cast(null as {{ type_string() }}) as app_error__exception_name
, cast(null as {{ type_boolean() }}) as app_error__is_fatal
, cast(null as {{ type_int() }}) as app_error__line_number
, cast(null as {{ type_string() }}) as app_error__stack_trace
, cast(null as {{ type_int() }}) as app_error__thread_id
, cast(null as {{ type_string() }}) as app_error__thread_name
, cast(null as {{ dbt.type_string() }}) as app_error__message
, cast(null as {{ dbt.type_string() }}) as app_error__programming_language
, cast(null as {{ dbt.type_string() }}) as app_error__class_name
, cast(null as {{ dbt.type_string() }}) as app_error__exception_name
, cast(null as {{ dbt.type_boolean() }}) as app_error__is_fatal
, cast(null as {{ dbt.type_int() }}) as app_error__line_number
, cast(null as {{ dbt.type_string() }}) as app_error__stack_trace
, cast(null as {{ dbt.type_int() }}) as app_error__thread_id
, cast(null as {{ dbt.type_string() }}) as app_error__thread_name
{% endif %}
{% endmacro %}

Expand All @@ -70,15 +70,15 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, unstruct_event_com_snowplowanalytics_snowplow_application_error_1.thread_id::INT AS app_error__thread_id
, unstruct_event_com_snowplowanalytics_snowplow_application_error_1.thread_name::STRING AS app_error__thread_name
{% else %}
, cast(null as {{ type_string() }}) as app_error__message
, cast(null as {{ type_string() }}) as app_error__programming_language
, cast(null as {{ type_string() }}) as app_error__class_name
, cast(null as {{ type_string() }}) as app_error__exception_name
, cast(null as {{ type_boolean() }}) as app_error__is_fatal
, cast(null as {{ type_int() }}) as app_error__line_number
, cast(null as {{ type_string() }}) as app_error__stack_trace
, cast(null as {{ type_int() }}) as app_error__thread_id
, cast(null as {{ type_string() }}) as app_error__thread_name
, cast(null as {{ dbt.type_string() }}) as app_error__message
, cast(null as {{ dbt.type_string() }}) as app_error__programming_language
, cast(null as {{ dbt.type_string() }}) as app_error__class_name
, cast(null as {{ dbt.type_string() }}) as app_error__exception_name
, cast(null as {{ dbt.type_boolean() }}) as app_error__is_fatal
, cast(null as {{ dbt.type_int() }}) as app_error__line_number
, cast(null as {{ dbt.type_string() }}) as app_error__stack_trace
, cast(null as {{ dbt.type_int() }}) as app_error__thread_id
, cast(null as {{ dbt.type_string() }}) as app_error__thread_name
{% endif %}
{% endmacro %}

Expand All @@ -94,14 +94,14 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, unstruct_event_com_snowplowanalytics_snowplow_application_error_1:threadId::INT AS app_error__thread_id
, unstruct_event_com_snowplowanalytics_snowplow_application_error_1:threadName::VARCHAR() AS app_error__thread_name
{% else %}
, cast(null as {{ type_string() }}) as app_error__message
, cast(null as {{ type_string() }}) as app_error__programming_language
, cast(null as {{ type_string() }}) as app_error__class_name
, cast(null as {{ type_string() }}) as app_error__exception_name
, cast(null as {{ type_boolean() }}) as app_error__is_fatal
, cast(null as {{ type_int() }}) as app_error__line_number
, cast(null as {{ type_string() }}) as app_error__stack_trace
, cast(null as {{ type_int() }}) as app_error__thread_id
, cast(null as {{ type_string() }}) as app_error__thread_name
, cast(null as {{ dbt.type_string() }}) as app_error__message
, cast(null as {{ dbt.type_string() }}) as app_error__programming_language
, cast(null as {{ dbt.type_string() }}) as app_error__class_name
, cast(null as {{ dbt.type_string() }}) as app_error__exception_name
, cast(null as {{ dbt.type_boolean() }}) as app_error__is_fatal
, cast(null as {{ dbt.type_int() }}) as app_error__line_number
, cast(null as {{ dbt.type_string() }}) as app_error__stack_trace
, cast(null as {{ dbt.type_int() }}) as app_error__thread_id
, cast(null as {{ dbt.type_string() }}) as app_error__thread_name
{% endif %}
{% endmacro %}
90 changes: 45 additions & 45 deletions macros/field_extractions/get_browser_context_fields.sql
View file
Original file line number Diff line number Diff line change
Expand Up @@ -15,15 +15,15 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, cast(null as {{ snowplow_utils.type_max_string() }}) as browser__viewport
, cast(null as {{ snowplow_utils.type_max_string() }}) as browser__document_size
, cast(null as {{ snowplow_utils.type_max_string() }}) as browser__resolution
, cast(null as {{ type_int() }}) as browser__color_depth
, cast(null as {{ dbt.type_int() }}) as browser__color_depth
, cast(null as {{ snowplow_utils.type_max_string() }}) as browser__device_pixel_ratio
, cast(null as {{ type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ type_boolean() }}) as browser__online
, cast(null as {{ dbt.type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ dbt.type_boolean() }}) as browser__online
, cast(null as {{ snowplow_utils.type_max_string() }}) as browser__browser_language
, cast(null as {{ snowplow_utils.type_max_string() }}) as browser__document_language
, cast(null as {{ type_boolean() }}) as browser__webdriver
, cast(null as {{ type_int() }}) as browser__device_memory
, cast(null as {{ type_int() }}) as browser__hardware_concurrency
, cast(null as {{ dbt.type_boolean() }}) as browser__webdriver
, cast(null as {{ dbt.type_int() }}) as browser__device_memory
, cast(null as {{ dbt.type_int() }}) as browser__hardware_concurrency
, cast(null as {{ snowplow_utils.type_max_string() }}) as browser__tab_id
{% endif %}
{% endmacro %}
Expand Down Expand Up @@ -54,19 +54,19 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
relation=source('atomic', 'events') if 'integration_tests' not in project_name and 'snowplow' not in project_name else ref('snowplow_unified_events_stg'),
relation_alias=none) }}
{% else %}
, cast(null as {{ type_string() }}) as browser__viewport
, cast(null as {{ type_string() }}) as browser__document_size
, cast(null as {{ type_string() }}) as browser__resolution
, cast(null as {{ type_int() }}) as browser__color_depth
, cast(null as {{ type_float() }}) as browser__device_pixel_ratio
, cast(null as {{ type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ type_boolean() }}) as browser__online
, cast(null as {{ type_string() }}) as browser__browser_language
, cast(null as {{ type_string() }}) as browser__document_language
, cast(null as {{ type_boolean() }}) as browser__webdriver
, cast(null as {{ type_int() }}) as browser__device_memory
, cast(null as {{ type_int() }}) as browser__hardware_concurrency
, cast(null as {{ type_string() }}) as browser__tab_id
, cast(null as {{ dbt.type_string() }}) as browser__viewport
, cast(null as {{ dbt.type_string() }}) as browser__document_size
, cast(null as {{ dbt.type_string() }}) as browser__resolution
, cast(null as {{ dbt.type_int() }}) as browser__color_depth
, cast(null as {{ dbt.type_float() }}) as browser__device_pixel_ratio
, cast(null as {{ dbt.type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ dbt.type_boolean() }}) as browser__online
, cast(null as {{ dbt.type_string() }}) as browser__browser_language
, cast(null as {{ dbt.type_string() }}) as browser__document_language
, cast(null as {{ dbt.type_boolean() }}) as browser__webdriver
, cast(null as {{ dbt.type_int() }}) as browser__device_memory
, cast(null as {{ dbt.type_int() }}) as browser__hardware_concurrency
, cast(null as {{ dbt.type_string() }}) as browser__tab_id
{% endif %}
{% endmacro %}

Expand All @@ -86,19 +86,19 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, contexts_com_snowplowanalytics_snowplow_browser_context_1[0].hardware_concurrency::INT AS browser__hardware_concurrency
, contexts_com_snowplowanalytics_snowplow_browser_context_1[0].tab_id::STRING AS browser__tab_id
{% else %}
, cast(null as {{ type_string() }}) as browser__viewport
, cast(null as {{ type_string() }}) as browser__document_size
, cast(null as {{ type_string() }}) as browser__resolution
, cast(null as {{ type_int() }}) as browser__color_depth
, cast(null as {{ type_float() }}) as browser__device_pixel_ratio
, cast(null as {{ type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ type_boolean() }}) as browser__online
, cast(null as {{ type_string() }}) as browser__browser_language
, cast(null as {{ type_string() }}) as browser__document_language
, cast(null as {{ type_boolean() }}) as browser__webdriver
, cast(null as {{ type_int() }}) as browser__device_memory
, cast(null as {{ type_int() }}) as browser__hardware_concurrency
, cast(null as {{ type_string() }}) as browser__tab_id
, cast(null as {{ dbt.type_string() }}) as browser__viewport
, cast(null as {{ dbt.type_string() }}) as browser__document_size
, cast(null as {{ dbt.type_string() }}) as browser__resolution
, cast(null as {{ dbt.type_int() }}) as browser__color_depth
, cast(null as {{ dbt.type_float() }}) as browser__device_pixel_ratio
, cast(null as {{ dbt.type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ dbt.type_boolean() }}) as browser__online
, cast(null as {{ dbt.type_string() }}) as browser__browser_language
, cast(null as {{ dbt.type_string() }}) as browser__document_language
, cast(null as {{ dbt.type_boolean() }}) as browser__webdriver
, cast(null as {{ dbt.type_int() }}) as browser__device_memory
, cast(null as {{ dbt.type_int() }}) as browser__hardware_concurrency
, cast(null as {{ dbt.type_string() }}) as browser__tab_id

{% endif %}
{% endmacro %}
Expand All @@ -119,18 +119,18 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
, contexts_com_snowplowanalytics_snowplow_browser_context_1[0]:hardwareConcurrency::int AS browser__hardware_concurrency
, contexts_com_snowplowanalytics_snowplow_browser_context_1[0]:tabId::varchar AS browser__tab_id
{% else %}
, cast(null as {{ type_string() }}) as browser__viewport
, cast(null as {{ type_string() }}) as browser__document_size
, cast(null as {{ type_string() }}) as browser__resolution
, cast(null as {{ type_int() }}) as browser__color_depth
, cast(null as {{ type_float() }}) as browser__device_pixel_ratio
, cast(null as {{ type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ type_boolean() }}) as browser__online
, cast(null as {{ type_string() }}) as browser__browser_language
, cast(null as {{ type_string() }}) as browser__document_language
, cast(null as {{ type_boolean() }}) as browser__webdriver
, cast(null as {{ type_int() }}) as browser__device_memory
, cast(null as {{ type_int() }}) as browser__hardware_concurrency
, cast(null as {{ type_string() }}) as browser__tab_id
, cast(null as {{ dbt.type_string() }}) as browser__viewport
, cast(null as {{ dbt.type_string() }}) as browser__document_size
, cast(null as {{ dbt.type_string() }}) as browser__resolution
, cast(null as {{ dbt.type_int() }}) as browser__color_depth
, cast(null as {{ dbt.type_float() }}) as browser__device_pixel_ratio
, cast(null as {{ dbt.type_boolean() }}) as browser__cookies_enabled
, cast(null as {{ dbt.type_boolean() }}) as browser__online
, cast(null as {{ dbt.type_string() }}) as browser__browser_language
, cast(null as {{ dbt.type_string() }}) as browser__document_language
, cast(null as {{ dbt.type_boolean() }}) as browser__webdriver
, cast(null as {{ dbt.type_int() }}) as browser__device_memory
, cast(null as {{ dbt.type_int() }}) as browser__hardware_concurrency
, cast(null as {{ dbt.type_string() }}) as browser__tab_id
{% endif %}
{% endmacro %}
Loading

0 comments on commit 416aad7

Please sign in to comment.