diff --git a/models/silver/silver__stake_events.sql b/models/silver/silver__stake_events.sql index 59c7575..b22788d 100644 --- a/models/silver/silver__stake_events.sql +++ b/models/silver/silver__stake_events.sql @@ -22,6 +22,6 @@ SELECT ) AS _INSERTED_TIMESTAMP FROM {{ ref('bronze__stake_events') }} - qualify(ROW_NUMBER() over(PARTITION BY pool, rune_tx, asset_chain, stake_units, rune_addr, asset_tx, asset_addr, block_timestamp + qualify(ROW_NUMBER() over(PARTITION BY event_id, pool, rune_tx, asset_chain, stake_units, rune_addr, asset_tx, asset_addr, block_timestamp ORDER BY __HEVO__INGESTED_AT DESC)) = 1 diff --git a/models/silver/silver__stake_events.yml b/models/silver/silver__stake_events.yml index c7a8420..f8d17e8 100644 --- a/models/silver/silver__stake_events.yml +++ b/models/silver/silver__stake_events.yml @@ -12,6 +12,7 @@ models: - RUNE_TX_ID - RUNE_ADDRESS - BLOCK_TIMESTAMP + - EVENT_ID columns: - name: POOL_NAME tests: