This commit is contained in:
Eric Laurello 2023-06-06 15:37:39 -04:00
parent 68dc3c862e
commit 4608243d86

View File

@ -1,5 +1,8 @@
{{ config(
materialized = 'view'
materialized = 'incremental',
unique_key = ["block_hour", "currency"],
incremental_strategy = 'merge',
cluster_by = ['block_hour::DATE'],
) }}
WITH swaps AS (
@ -35,9 +38,20 @@ 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 qualify(RANK() over(
ORDER BY
block_hour DESC)) <> 1
AND t.raw_metadata [1] :exponent IS NOT NULL
{% if is_incremental() %}
AND block_hour >=(
SELECT
DATEADD('day', -3, MAX(block_hour :: DATE))
FROM
{{ this }}
)
{% endif %}
qualify(RANK() over(
ORDER BY
block_hour DESC)) <> 1
),
swap_range AS (
SELECT
@ -163,8 +177,17 @@ osmo_price_hour AS (
WHERE
price_denom = 'uosmo'
AND token_address = 'ibc/D189335C6E4A68B513C10AB227BF1C1D38C746766278BA3EEB4FB14124F1D858' --axUSDC
GROUP BY
block_hour
{% if is_incremental() %}
AND block_hour >=(
SELECT
DATEADD('day', -3, MAX(block_hour :: DATE))
FROM
{{ this }}
)
{% endif %}
GROUP BY
block_hour
),
osmo AS (
SELECT