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

upd lookback in tx res cte (#241)

Browse Source 
* upd lookback in tx res cte

* autofmt
This commit is contained in:
Jack Forgash 2023-12-06 16:13:17 -07:00 committed by GitHub
parent 971d555dff
commit 28e4dd0981
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
models/silver/core/silver__streamline_transactions_final.sql
View File

@ -52,17 +52,17 @@
{% set run = run_query(query ~ incr) %}
{% endif %}
/*
Do this because snowflake does not do well with dynamic query pruning.
This will set a "static" timestamp value which will always enable query pruning if the timestamp is a cluster key
Coalesce in case there are 0 txs returned by the temp table
*/
{% if execute %}
{% set min_time = run_query("select coalesce(min(_inserted_timestamp),current_timestamp()) from silver.streamline_transactions_final_intermediate_tmp").columns[0].values()[0] %}
{% set min_time = run_query("select coalesce(min(_inserted_timestamp),current_timestamp()) from silver.streamline_transactions_final_intermediate_tmp").columns [0].values() [0] %}
{% endif %}
WITH txs AS (
SELECT
*
FROM
@ -76,7 +76,13 @@ tx_results AS (
{% if is_incremental() %}
WHERE
_inserted_timestamp >= '{{ min_time }}'
_inserted_timestamp >= SYSDATE() - INTERVAL '3 days'
AND tx_id IN (
SELECT
DISTINCT tx_id
FROM
silver.streamline_transactions_final_intermediate_tmp
)
{% endif %}
),
blocks AS (
@ -87,15 +93,13 @@ blocks AS (
{% if is_incremental() %}
WHERE
DATE_TRUNC(
'day',
_inserted_timestamp
) >= (
_inserted_timestamp >= SYSDATE() - INTERVAL '3 days'
AND block_number IN (
SELECT
MAX(DATE_TRUNC('day', _inserted_timestamp))
DISTINCT block_number
FROM
{{ this }}
) - INTERVAL '3 days'
silver.streamline_transactions_final_intermediate_tmp
)
{% endif %}
),
FINAL AS (
@ -129,7 +133,9 @@ FINAL AS (
t.script,
tr.error_message,
tr.events,
ARRAY_SIZE(tr.events) AS events_count,
ARRAY_SIZE(
tr.events
) AS events_count,
tr.status,
tr.status_code,
GREATEST(