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

AN-3898/fix qualify in silver load models (#181)

Browse Source 
* fix qualify

* del txs alias
This commit is contained in:
Jack Forgash 2023-09-05 13:42:49 -06:00 committed by GitHub
parent 5cedbce02a
commit aca459a005
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
models/silver/core/streamline/silver__streamline_collections.sql
View File

@ -30,6 +30,6 @@ WHERE
{{ ref('bronze__streamline_fr_collections') }}
{% endif %}
qualify(ROW_NUMBER() over (PARTITION BY block_number
qualify(ROW_NUMBER() over (PARTITION BY collection_id
ORDER BY
_inserted_timestamp DESC)) = 1

8
models/silver/core/streamline/silver__streamline_transaction_results.sql
View File

@ -18,7 +18,7 @@ SELECT
FROM
{% if is_incremental() %}
{{ ref('bronze__streamline_transaction_results') }} AS t
{{ ref('bronze__streamline_transaction_results') }}
WHERE
_inserted_timestamp >= (
SELECT
@ -27,9 +27,9 @@ WHERE
{{ this }}
)
{% else %}
{{ ref('bronze__streamline_fr_transaction_results') }} AS t
{{ ref('bronze__streamline_fr_transaction_results') }}
{% endif %}
qualify(ROW_NUMBER() over (PARTITION BY t.block_number
qualify(ROW_NUMBER() over (PARTITION BY tx_id
ORDER BY
t._inserted_timestamp DESC)) = 1
_inserted_timestamp DESC)) = 1

2
models/silver/core/streamline/silver__streamline_transactions.sql
View File

@ -35,6 +35,6 @@ WHERE
{{ ref('bronze__streamline_fr_transactions') }}
{% endif %}
qualify(ROW_NUMBER() over (PARTITION BY block_number
qualify(ROW_NUMBER() over (PARTITION BY tx_id
ORDER BY
_inserted_timestamp DESC)) = 1