fix duplicated unique key (#1428)

models/safe/ethereum/safe_ethereum_eth_transfers.sql

@@ -3,7 +3,7 @@
         materialized='incremental',
         alias='eth_transfers',
         partition_by = ['block_date'],
-        unique_key = ['block_date', 'tx_hash', 'trace_address'],
+        unique_key = ['block_date', 'tx_hash', 'trace_address', 'amount_raw'],
         on_schema_change='fail',
         file_format ='delta',
         incremental_strategy='merge'
@@ -20,8 +20,9 @@ select
 from {{ source('ethereum', 'traces') }} et
 join {{ ref('safe_ethereum_safes') }} s on et.from = s.address
     and et.from != et.to -- exclude calls to self to guarantee unique key property
-    and success = true
-    and (lower(call_type) not in ('delegatecall', 'callcode', 'staticcall') or call_type is null)    
+    and et.success = true
+    and (lower(et.call_type) not in ('delegatecall', 'callcode', 'staticcall') or et.call_type is null)
+    and et.value > 0 -- exclue 0 value traces
 where et.block_time > '2018-11-24' -- for initial query optimisation
 {% if is_incremental() %}
 -- to prevent potential counterfactual safe deployment issues we take a bigger interval
@@ -40,8 +41,9 @@ select
 from {{ source('ethereum', 'traces') }} et
 join {{ ref('safe_ethereum_safes') }} s on et.to = s.address
     and et.from != et.to -- exclude calls to self to guarantee unique key property
-    and success = true
-    and (lower(call_type) not in ('delegatecall', 'callcode', 'staticcall') or call_type is null)
+    and et.success = true
+    and (lower(et.call_type) not in ('delegatecall', 'callcode', 'staticcall') or et.call_type is null)
+    and et.value > 0 -- exclue 0 value traces
 where et.block_time > '2018-11-24' -- for initial query optimisation
 {% if is_incremental() %}
 -- to prevent potential counterfactual safe deployment issues we take a bigger interval