fix tests

This commit is contained in:
Mike Stepanovic 2024-12-13 15:16:12 -07:00
parent 8bac0a35c2
commit f7718fca5b
8 changed files with 23 additions and 1 deletions

View File

@ -488,6 +488,7 @@ joined AS (
total_stake * synth_depth / ((asset_depth * 2) - synth_depth) AS synth_units,
CASE
WHEN total_stake = 0 THEN 0
WHEN depth_product < 0 THEN 0
ELSE SQRT(depth_product) / (
total_stake + synth_units
)

View File

@ -18,3 +18,9 @@ FROM
{{ ref(
'bronze__rune_pool_deposit_events'
) }}
QUALIFY(
ROW_NUMBER() OVER (
PARTITION BY event_id
ORDER BY __HEVO__LOADED_AT DESC
) = 1
)

View File

@ -22,3 +22,9 @@ FROM
{{ ref(
'bronze__rune_pool_withdraw_events'
) }}
QUALIFY(
ROW_NUMBER() OVER (
PARTITION BY event_id
ORDER BY __HEVO__LOADED_AT DESC
) = 1
)

View File

@ -26,3 +26,9 @@ SELECT
) AS _INSERTED_TIMESTAMP
FROM
{{ ref('bronze__scheduled_outbound_events') }}
QUALIFY(
ROW_NUMBER() OVER (
PARTITION BY event_id
ORDER BY __HEVO__LOADED_AT DESC
) = 1
)

View File

@ -22,6 +22,6 @@ SELECT
) AS _INSERTED_TIMESTAMP
FROM
{{ ref('bronze__stake_events') }}
qualify(ROW_NUMBER() over(PARTITION BY event_id, pool, rune_tx, asset_chain, stake_units, rune_addr, asset_tx, asset_addr, block_timestamp
qualify(ROW_NUMBER() over(PARTITION BY pool, rune_tx, asset_chain, stake_units, rune_addr, asset_tx, asset_addr, block_timestamp
ORDER BY
__HEVO__INGESTED_AT DESC)) = 1

View File

@ -20,6 +20,7 @@ models:
- LIQ_FEE_IN_RUNE_E8
- _DIRECTION
- BLOCK_TIMESTAMP
- EVENT_ID
columns:
- name: TX_ID
tests:

View File

@ -8,6 +8,7 @@ models:
- CURRENT_STATUS
- FORMER_STATUS
- BLOCK_TIMESTAMP
- EVENT_ID
columns:
- name: NODE_ADDRESS
tests:

View File

@ -12,6 +12,7 @@ models:
- MEMO
- POOL_NAME
- BLOCK_TIMESTAMP
- EVENT_ID
columns:
- name: TX_ID
tests: