force 0x2::sui::SUI into prices
Some checks are pending
docs_update / run_dbt_jobs (push) Waiting to run
docs_update / notify-failure (push) Blocked by required conditions

This commit is contained in:
Eric Laurello 2025-11-05 21:12:33 -05:00
parent 4474f1c3ae
commit 24f0dfa45c

View File

@ -9,6 +9,57 @@
tags = ['gold_prices','core']
) }}
WITH base AS (
SELECT
*
FROM
{{ ref('silver__complete_token_prices') }}
{% if is_incremental() %}
WHERE
modified_timestamp > (
SELECT
COALESCE(MAX(modified_timestamp), '1970-01-01' :: TIMESTAMP) AS modified_timestamp
FROM
{{ this }})
{% endif %}
),
fin AS (
SELECT
HOUR,
token_address,
symbol,
NAME,
decimals,
price,
blockchain,
is_deprecated,
is_imputed,
is_verified,
complete_token_prices_id,
modified_timestamp
FROM
base
UNION ALL
SELECT
HOUR,
'0x2::sui::SUI' AS token_address,
symbol,
NAME,
decimals,
price,
blockchain,
is_deprecated,
is_imputed,
is_verified,
complete_token_prices_id,
modified_timestamp
FROM
base
WHERE
token_address = '0x0000000000000000000000000000000000000000000000000000000000000002::sui::SUI'
)
SELECT
HOUR,
token_address,
@ -31,13 +82,9 @@ SELECT
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp
FROM
{{ ref('silver__complete_token_prices') }}
{% if is_incremental() %}
WHERE
modified_timestamp > (
SELECT
COALESCE(MAX(modified_timestamp), '1970-01-01' :: TIMESTAMP) AS modified_timestamp
FROM
{{ this }})
{% endif %}
fin qualify ROW_NUMBER() over (
PARTITION BY HOUR,
token_address
ORDER BY
modified_timestamp DESC
) = 1