mark_distinct_strategy macro (duneanalytics#4671)

clizzard7 · Oct 25, 2023 · 664b829 · 664b829
1 parent 5775d83
commit 664b829
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/macros/mark_distinct_strategy.sql b/macros/mark_distinct_strategy.sql
@@ -0,0 +1,3 @@
+{% macro mark_distinct_strategy(value) %}
+  {{ set_trino_session_property(true, 'mark_distinct_strategy', value) }}
+{% endmacro %}
diff --git a/models/maker/ethereum/maker_ethereum_accounting.sql b/models/maker/ethereum/maker_ethereum_accounting.sql
@@ -4,6 +4,7 @@
         partition_by = ['dt'],
         materialized = 'table',
         file_format = 'delta',
+        pre_hook='{{ mark_distinct_strategy(None) }}',
         post_hook='{{ expose_spells(\'["ethereum"]\',
                                 "project",
                                 "maker",