Skip to content

Commit a0e23e4

Browse files
wallet contract hour merge key (#1249)
1 parent ee32cbb commit a0e23e4

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

spellbook/models/transfers/ethereum/erc20/transfers_ethereum_erc20_agg_hour.sql

+8-4
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
materialized ='incremental',
44
file_format ='delta',
55
incremental_strategy='merge',
6-
unique_key='unique_transfer_id'
6+
unique_key='wallet_contract_hour'
77
)
88
}}
99

@@ -13,14 +13,18 @@ select
1313
tr.wallet_address,
1414
tr.token_address,
1515
t.symbol,
16+
tr.wallet_address || '-' || tr.token_address || '-' || date_trunc('hour', tr.evt_block_time) as wallet_contract_hour,
1617
sum(tr.amount_raw) as amount_raw,
17-
sum(tr.amount_raw / power(10, t.decimals)) as amount,
18-
unique_tx_id || '-' || wallet_address || '-' || token_address || '-' || sum(tr.amount_raw)::string as unique_transfer_id
18+
sum(tr.amount_raw / power(10, t.decimals)) as amount
1919
from {{ ref('transfers_ethereum_erc20') }} tr
2020
left join {{ ref('tokens_ethereum_erc20') }} t on t.contract_address = tr.token_address
2121
{% if is_incremental() %}
2222
-- this filter will only be applied on an incremental run
2323
where date_trunc('hour', tr.evt_block_time) > now() - interval 2 days
2424
{% endif %}
2525
group by
26-
date_trunc('hour', tr.evt_block_time), tr.wallet_address, tr.token_address, t.symbol,unique_tx_id
26+
date_trunc('hour', tr.evt_block_time),
27+
tr.wallet_address,
28+
tr.token_address,
29+
t.symbol,
30+
tr.wallet_address || '-' || tr.token_address || '-' || date_trunc('hour', tr.evt_block_time)

0 commit comments

Comments
 (0)