flip/thorchain-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/thorchain-models.git synced 2026-02-06 15:56:45 +00:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

addressed PR comments: added 1 hour look back and/or 2 day clock skew buffer, removed unnecessary health checks, switched core__dim_block incremental logic to block_id

Browse Source
This commit is contained in:
Mike Stepanovic 2024-07-26 11:59:33 -06:00
parent 04f65700b9
commit 70eee16b54
78 changed files with 170 additions and 209 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
models/gold/core/core__dim_block.sql
View File

@ -2,7 +2,7 @@
materialized = 'incremental',
unique_key = 'dim_block_id',
incremental_strategy = 'merge',
incremental_predicates = ['DBT_INTERNAL_DEST.block_timestamp >= (select min(block_timestamp) from ' ~ generate_tmp_view_name(this) ~ ')'],
incremental_predicates = ['DBT_INTERNAL_DEST.block_id >= (select min(block_id) from ' ~ generate_tmp_view_name(this) ~ ')'],
cluster_by = ['block_timestamp::DATE']
) }}
@ -30,18 +30,16 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
{{ ref('silver__block_log') }}
{% if is_incremental() %}
WHERE
block_timestamp >= (
block_id >= (
SELECT
MAX(
block_timestamp
block_id - 600 --about 1 hour
)
FROM
{{ this }}
)
{% endif %}
UNION ALL
SELECT
'-1' AS dim_block_id,
@ -63,17 +61,6 @@ SELECT
'{{ invocation_id }}' AS _audit_run_id,
'1900-01-01' :: DATE AS inserted_timestamp,
'1900-01-01' :: DATE AS modified_timestamp
{% if is_incremental() %}
WHERE
block_timestamp >= (
SELECT
MAX(
block_timestamp
)
FROM
{{ this }}
)
{% endif %}
UNION ALL
SELECT
'-2' AS dim_block_id,
@ -95,14 +82,4 @@ SELECT
'{{ invocation_id }}' AS _audit_run_id,
'1900-01-01' :: DATE AS inserted_timestamp,
'1900-01-01' :: DATE AS modified_timestamp
{% if is_incremental() %}
WHERE
block_timestamp >= (
SELECT
MAX(
block_timestamp
)
FROM
{{ this }}
)
{% endif %}

4
models/gold/core/core__fact_network_version_events.sql
View File

@ -34,7 +34,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -42,7 +42,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/core/core__fact_set_mimir_events.sql
View File

@ -35,7 +35,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -43,7 +43,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/core/core__fact_thorname_change_events.sql
View File

@ -45,7 +45,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -53,7 +53,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/core/core__fact_transfer_events.sql
View File

@ -39,7 +39,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -47,7 +47,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/core/core__fact_transfers.sql
View File

@ -26,7 +26,7 @@ WHERE
block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
@ -53,6 +53,6 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_id = b.block_id

4
models/gold/core/core__fact_tss_keygen_failure_events.sql
View File

@ -42,7 +42,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -50,7 +50,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/core/core__fact_tss_keygen_success_events.sql
View File

@ -38,7 +38,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -46,7 +46,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

12
models/gold/defi/defi__fact_active_vault_events.sql
View File

@ -33,7 +33,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -41,17 +41,9 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
)
OR add_asgard_addr IN (
SELECT
add_asgard_addr
FROM
{{ this }}
WHERE
dim_block_id = '-1'
)
{% endif %}

4
models/gold/defi/defi__fact_add_events.sql
View File

@ -51,7 +51,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -59,7 +59,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_asgard_fund_yggdrasil_events.sql
View File

@ -39,7 +39,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -47,7 +47,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_block_pool_depths.sql
View File

@ -38,7 +38,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -46,7 +46,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/gold/defi/defi__fact_block_rewards.sql
View File

@ -25,7 +25,7 @@ WHERE
DAY >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_bond_actions.sql
View File

@ -63,7 +63,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
bond_events be
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON be.block_timestamp = b.timestamp
LEFT JOIN block_prices p
@ -73,7 +73,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_bond_events.sql
View File

@ -50,7 +50,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -58,7 +58,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/gold/defi/defi__fact_daily_earnings.sql
View File

@ -30,7 +30,7 @@ WHERE
DAY >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

2
models/gold/defi/defi__fact_daily_pool_stats.sql
View File

@ -58,7 +58,7 @@ WHERE
DAY >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

2
models/gold/defi/defi__fact_daily_tvl.sql
View File

@ -25,7 +25,7 @@ WHERE
DAY >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_errata_events.sql
View File

@ -39,7 +39,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -47,7 +47,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_fee_events.sql
View File

@ -39,7 +39,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -47,7 +47,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_gas_events.sql
View File

@ -39,7 +39,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -47,7 +47,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

12
models/gold/defi/defi__fact_inactive_vault_events.sql
View File

@ -33,7 +33,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -41,17 +41,9 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
)
OR add_asgard_address IN (
SELECT
add_asgard_address
FROM
{{ this }}
WHERE
dim_block_id = '-1'
)
{% endif %}

4
models/gold/defi/defi__fact_liquidity_actions.sql
View File

@ -65,7 +65,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_id = b.block_id
{% if is_incremental() %}
@ -73,7 +73,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_loan_open_events.sql
View File

@ -50,7 +50,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -58,7 +58,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_loan_repayment_events.sql
View File

@ -48,7 +48,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -56,7 +56,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_mint_burn_events.sql
View File

@ -40,7 +40,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -48,7 +48,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_outbound_events.sql
View File

@ -49,7 +49,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -57,7 +57,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_pending_liquidity_events.sql
View File

@ -49,7 +49,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -57,7 +57,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_pool_balance_change_events.sql
View File

@ -43,7 +43,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -51,7 +51,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_pool_block_balances.sql
View File

@ -45,7 +45,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_id = b.block_id
{% if is_incremental() %}
@ -53,7 +53,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/gold/defi/defi__fact_pool_block_fees.sql
View File

@ -27,7 +27,7 @@ WHERE
DAY >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

2
models/gold/defi/defi__fact_pool_block_statistics.sql
View File

@ -56,7 +56,7 @@ WHERE
DAY >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_pool_events.sql
View File

@ -35,7 +35,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -43,7 +43,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_refund_events.sql
View File

@ -54,7 +54,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -62,7 +62,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_reserve_events.sql
View File

@ -51,7 +51,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -59,7 +59,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_rewards_event_entries.sql
View File

@ -37,7 +37,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -45,7 +45,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_rewards_events.sql
View File

@ -33,7 +33,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -41,7 +41,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

22
models/gold/defi/defi__fact_scheduled_outbound_events.sql
View File

@ -60,7 +60,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -68,17 +68,17 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
)
OR event_id IN (
SELECT
event_id
FROM
{{ this }}
WHERE
dim_block_id = '-1'
)
{% endif %}
OR event_id IN (
SELECT
event_id
FROM
{{ this }}
WHERE
dim_block_id = '-1'
)
{% endif %}

4
models/gold/defi/defi__fact_send_messages.sql
View File

@ -44,7 +44,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -52,7 +52,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_stake_events.sql
View File

@ -51,7 +51,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -59,7 +59,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_streamling_swap_details_events.sql
View File

@ -60,7 +60,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -68,7 +68,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_swaps.sql
View File

@ -84,7 +84,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_id = b.block_id
{% if is_incremental() %}
@ -92,7 +92,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_swaps_events.sql
View File

@ -66,7 +66,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -74,7 +74,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_switch_events.sql
View File

@ -43,7 +43,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -51,7 +51,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_total_block_rewards.sql
View File

@ -37,7 +37,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_id = b.block_id
{% if is_incremental() %}
@ -45,7 +45,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/gold/defi/defi__fact_total_value_locked.sql
View File

@ -22,7 +22,7 @@ WHERE
DAY >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_trade_account_deposit_events.sql
View File

@ -42,7 +42,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -50,7 +50,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_trade_account_withdraw_events.sql
View File

@ -42,7 +42,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -50,7 +50,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_unstake_events.sql
View File

@ -61,7 +61,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -69,7 +69,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_update_node_account_status_events.sql
View File

@ -36,7 +36,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -44,7 +44,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

6
models/gold/defi/defi__fact_upgrades.sql
View File

@ -47,15 +47,15 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_id = b.block_id
{% if is_incremental() %}
WHERE
dim_block_id >= (
b.block_timestamp >= (
SELECT
MAX(
dim_block_id
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/defi/defi__fact_withdraw_events.sql
View File

@ -62,7 +62,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -70,7 +70,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/gov/gov__fact_new_node_events.sql
View File

@ -33,7 +33,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -41,7 +41,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/gov/gov__fact_set_ip_address_events.sql
View File

@ -35,7 +35,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -43,7 +43,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/gov/gov__fact_set_node_keys_events.sql
View File

@ -39,7 +39,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -47,7 +47,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/gov/gov__fact_set_version_events.sql
View File

@ -35,7 +35,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -43,7 +43,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/gov/gov__fact_slash_amounts.sql
View File

@ -37,7 +37,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -45,7 +45,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/gov/gov__fact_slash_points.sql
View File

@ -37,7 +37,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -45,7 +45,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/gov/gov__fact_validator_request_leave_events.sql
View File

@ -37,7 +37,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -45,7 +45,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/gold/price/price__fact_prices.sql
View File

@ -26,7 +26,7 @@ WHERE
block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
@ -52,6 +52,6 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_id = b.block_id

4
models/gold/price/price__fact_rune_price.sql
View File

@ -32,7 +32,7 @@ SELECT
SYSDATE() AS modified_timestamp
FROM
base A
LEFT JOIN {{ ref('core__dim_block') }}
JOIN {{ ref('core__dim_block') }}
b
ON A.block_timestamp = b.timestamp
{% if is_incremental() %}
@ -40,7 +40,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/silver/prices/silver__complete_native_asset_metadata.sql
View File

@ -29,7 +29,7 @@ WHERE
modified_timestamp >= (
SELECT
MAX(
modified_timestamp
modified_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/silver/prices/silver__complete_native_prices.sql
View File

@ -32,7 +32,7 @@ WHERE
modified_timestamp >= (
SELECT
MAX(
modified_timestamp
modified_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/silver/prices/silver__complete_provider_asset_metadata.sql
View File

@ -29,7 +29,7 @@ WHERE
modified_timestamp >= (
SELECT
MAX(
modified_timestamp
modified_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/silver/prices/silver__complete_provider_prices.sql
View File

@ -33,7 +33,7 @@ WHERE
p.modified_timestamp >= (
SELECT
MAX(
modified_timestamp
modified_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

10
models/silver/silver__block_rewards.sql
View File

@ -20,7 +20,7 @@ WHERE
) :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -49,7 +49,7 @@ WHERE
) :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -104,7 +104,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -130,7 +130,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -156,7 +156,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

6
models/silver/silver__daily_pool_stats.sql
View File

@ -22,7 +22,7 @@ WHERE
block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -54,7 +54,7 @@ WHERE
pbf.day >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -169,7 +169,7 @@ WHERE
pbs.day >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

4
models/silver/silver__daily_tvl.sql
View File

@ -22,7 +22,7 @@ WHERE
block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -47,7 +47,7 @@ WHERE
block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

4
models/silver/silver__liquidity_actions.sql
View File

@ -100,7 +100,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
@ -172,7 +172,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/silver/silver__pool_block_balances.sql
View File

@ -37,7 +37,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

10
models/silver/silver__pool_block_fees.sql
View File

@ -27,7 +27,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -55,7 +55,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -83,7 +83,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -118,7 +118,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -154,7 +154,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

26
models/silver/silver__pool_block_statistics.sql
View File

@ -41,7 +41,7 @@ WITH pool_depth AS (
AND b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -78,7 +78,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -109,7 +109,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -141,7 +141,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -178,7 +178,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -226,7 +226,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -277,7 +277,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -309,7 +309,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -339,7 +339,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -367,7 +367,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -396,7 +396,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -427,7 +427,7 @@ stake_umc AS (
AND b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -458,7 +458,7 @@ WHERE
AND b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

4
models/silver/silver__prices.sql
View File

@ -26,7 +26,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
@ -49,7 +49,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/silver/silver__swaps.sql
View File

@ -49,7 +49,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/silver/silver__total_block_rewards.sql
View File

@ -45,7 +45,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}
@ -98,7 +98,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

4
models/silver/silver__total_value_locked.sql
View File

@ -27,7 +27,7 @@ WHERE
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}
@ -87,7 +87,7 @@ AND
b.block_timestamp :: DATE >= (
SELECT
MAX(
DAY
DAY - INTERVAL '2 DAYS' --counteract clock skew
)
FROM
{{ this }}

2
models/silver/silver__transfers.sql
View File

@ -46,7 +46,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}

2
models/silver/silver__upgrades.sql
View File

@ -61,7 +61,7 @@ WHERE
b.block_timestamp >= (
SELECT
MAX(
block_timestamp
block_timestamp - INTERVAL '1 HOUR'
)
FROM
{{ this }}