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

Refactor streamline transaction results SQL to remove data size const… (#437)

Browse Source 
* Refactor streamline transaction results SQL to remove data size constraint

* Removed the OCTET_LENGTH(DATA) < 16777216 condition from the query.
* Cleaned up unnecessary comments and code related to data size checks.

* update

* update

* from
This commit is contained in:
SAI 2025-04-23 17:15:15 -05:00 committed by GitHub
parent 2e7d617fe7
commit 5dffab25ab
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
models/silver/core/silver__streamline_transaction_results.sql
View File

@ -25,7 +25,6 @@ SELECT
SYSDATE() AS modified_timestamp,
'{{ invocation_id }}' AS _invocation_id
FROM
{% if var('LOAD_BACKFILL', False) %}
{{ ref('bronze__streamline_transaction_results_history') }}
-- TODO need incremental logic of some sort probably (for those 5800 missing txs)
@ -34,8 +33,6 @@ FROM
{{ ref('bronze__streamline_fr_transaction_results') }}
WHERE
_partition_by_block_id BETWEEN {{ var('RANGE_START', 0) }} AND {{ var('RANGE_END', 0) }}
and
OCTET_LENGTH(DATA) < 16777216
{% else %}
{% if is_incremental() %}
@ -47,19 +44,15 @@ WHERE
FROM
{{ this }}
)
AND
OCTET_LENGTH(DATA) < 16777216
-- AND _partition_by_block_id > 107700000 -- march 27th 2025
-- AND _partition_by_block_id > 108000000 -- march 28th 2025
-- AND _partition_by_block_id > 108800000 -- april 5th 2025
{% else %}
{{ ref('bronze__streamline_fr_transaction_results') }}
WHERE
OCTET_LENGTH(DATA) < 16777216
{% endif %}
{% endif %}
qualify(ROW_NUMBER() over (PARTITION BY tx_id
ORDER BY
_inserted_timestamp DESC)) = 1
_inserted_timestamp DESC)) = 1