Lets change the logic here

snowplow · Oct 4, 2024 · fdef02a · fdef02a
1 parent fbe9a55
commit fdef02a
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 14 deletions.
diff --git a/integration_tests/models/actual/snowplow_ecommerce_cart_interactions_actual.sql b/integration_tests/models/actual/snowplow_ecommerce_cart_interactions_actual.sql
@@ -5,9 +5,9 @@ and you may not use this file except in compliance with the Snowplow Personal an
 You may obtain a copy of the Snowplow Personal and Academic License Version 1.0 at https://docs.snowplow.io/personal-and-academic-license-1.0/
 #}
 
-
-select * {% if target.type == 'databricks' %}
-  except(derived_tstamp_date)
+{% if target.type in ('databricks','spark') %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_cart_interactions'), except=['derived_tstamp_date'] )}}
+{% else %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_cart_interactions')) }}
 {% endif %}
-
 from {{ ref('snowplow_ecommerce_cart_interactions') }}
diff --git a/integration_tests/models/actual/snowplow_ecommerce_checkout_interactions_actual.sql b/integration_tests/models/actual/snowplow_ecommerce_checkout_interactions_actual.sql
@@ -6,8 +6,9 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
 #}
 
 
-select * {% if target.type == 'databricks' %}
-  except(derived_tstamp_date)
+{% if target.type in ('databricks','spark') %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_checkout_interactions'), except=['derived_tstamp_date'] )}}
+{% else %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_checkout_interactions')) }}
 {% endif %}
-
 from {{ ref('snowplow_ecommerce_checkout_interactions') }}
diff --git a/integration_tests/models/actual/snowplow_ecommerce_product_interactions_actual.sql b/integration_tests/models/actual/snowplow_ecommerce_product_interactions_actual.sql
@@ -6,8 +6,10 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
 #}
 
 
-select * {% if target.type == 'databricks' %}
-  except(derived_tstamp_date)
+{% if target.type in ('databricks','spark') %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_product_interactions'), except=['derived_tstamp_date'] )}}
+{% else %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_product_interactions')) }}
 {% endif %}
-
 from {{ ref('snowplow_ecommerce_product_interactions') }}
+
diff --git a/integration_tests/models/actual/snowplow_ecommerce_transaction_interactions_actual.sql b/integration_tests/models/actual/snowplow_ecommerce_transaction_interactions_actual.sql
@@ -6,8 +6,9 @@ You may obtain a copy of the Snowplow Personal and Academic License Version 1.0
 #}
 
 
-select * {% if target.type == 'databricks' %}
-  except(derived_tstamp_date)
+{% if target.type in ('databricks','spark') %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_transaction_interactions'), except=['derived_tstamp_date'] )}}
+{% else %}
+SELECT {{ dbt_utils.star(from=ref('snowplow_ecommerce_transaction_interactions')) }}
 {% endif %}
-
-from {{ ref('snowplow_ecommerce_transaction_interactions') }}
+from {{ ref('snowplow_ecommerce_transaction_interactions') }}