flip/aurora-models
1
0
Fork 0
mirror of https://github.com/FlipsideCrypto/aurora-models.git synced 2026-02-06 13:36:46 +00:00
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fix stats inc logic

Browse Source
This commit is contained in:
Eric Laurello 2024-03-01 13:12:27 -05:00
parent 6275341a86
commit 9b8940fd7a
2 changed files with 43 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
models/silver/stats/silver_stats__core_metrics_block_hourly.sql
View File

@ -5,7 +5,26 @@
cluster_by = ['block_timestamp_hour::DATE'],
tags = ['core']
) }}
/* run incremental timestamp value first then use it as a static value */
{% if execute %}
{% if is_incremental() %}
{% set query %}
SELECT
MIN(DATE_TRUNC('hour', block_timestamp)) block_timestamp_hour
FROM
{{ ref('silver__blocks') }}
WHERE
_inserted_timestamp >= (
SELECT
MAX(_inserted_timestamp)
FROM
{{ this }}
) {% endset %}
{% set min_block_timestamp_hour = run_query(query).columns [0].values() [0] %}
{% endif %}
{% endif %}
SELECT
DATE_TRUNC(
'hour',
@ -35,13 +54,8 @@ WHERE
{% if is_incremental() %}
AND DATE_TRUNC(
'hour',
_inserted_timestamp
) >= (
SELECT
MAX(DATE_TRUNC('hour', _inserted_timestamp)) - INTERVAL '12 hours'
FROM
{{ this }}
)
block_timestamp
) >= '{{ min_block_timestamp_hour }}'
{% endif %}
GROUP BY
1

30
models/silver/stats/silver_stats__core_metrics_hourly.sql
View File

@ -5,7 +5,26 @@
cluster_by = ['block_timestamp_hour::DATE'],
tags = ['core']
) }}
/* run incremental timestamp value first then use it as a static value */
{% if execute %}
{% if is_incremental() %}
{% set query %}
SELECT
MIN(DATE_TRUNC('hour', block_timestamp)) block_timestamp_hour
FROM
{{ ref('silver__transactions') }}
WHERE
_inserted_timestamp >= (
SELECT
MAX(_inserted_timestamp)
FROM
{{ this }}
) {% endset %}
{% set min_block_timestamp_hour = run_query(query).columns [0].values() [0] %}
{% endif %}
{% endif %}
SELECT
DATE_TRUNC(
'hour',
@ -46,13 +65,8 @@ WHERE
{% if is_incremental() %}
AND DATE_TRUNC(
'hour',
_inserted_timestamp
) >= (
SELECT
MAX(DATE_TRUNC('hour', _inserted_timestamp)) - INTERVAL '12 hours'
FROM
{{ this }}
)
block_timestamp
) >= '{{ min_block_timestamp_hour }}'
{% endif %}
GROUP BY
1
1