prices swaps to table

This commit is contained in:
Eric Laurello 2023-06-06 12:58:23 -04:00
parent 086d14d955
commit 828a8789df

View File

@ -1,6 +1,8 @@
{{ config(
materialized = 'table',
cluster_by = ['block_hour']
materialized = 'incremental',
unique_key = ["block_hour", "currency"],
incremental_strategy = 'merge',
cluster_by = ['block_hour::DATE'],
) }}
WITH swaps AS (
@ -36,16 +38,17 @@ WITH swaps AS (
TRY_TO_NUMBER(from_amount) > 0
AND TRY_TO_NUMBER(to_amount) > 0
AND f.raw_metadata [1] :exponent IS NOT NULL
AND t.raw_metadata [1] :exponent IS NOT NULL {# {% if is_incremental() %}
AND t.raw_metadata [1] :exponent IS NOT NULL
{% if is_incremental() %}
AND block_hour >=(
SELECT
DATEADD('day', -1, MAX(block_hour :: DATE))
DATEADD('day', -3, MAX(block_hour :: DATE))
FROM
{{ this }}
)
{% endif %}
#}
qualify(RANK() over(
ORDER BY
block_hour DESC)) <> 1
@ -174,16 +177,15 @@ osmo_price_hour AS (
WHERE
price_denom = 'uosmo'
AND token_address = 'ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858' --axUSDC
{# {% if is_incremental() %}
{% if is_incremental() %}
AND block_hour >=(
SELECT
DATEADD('day', -1, MAX(block_hour :: DATE))
DATEADD('day', -3, MAX(block_hour :: DATE))
FROM
{{ this }}
)
{% endif %}
#}
GROUP BY
block_hour
),