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

fix contract events PK

Browse Source
This commit is contained in:
Eric Laurello 2025-05-22 16:53:37 -04:00
parent 171d683768
commit fad0deb650
2 changed files with 7 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -24,9 +24,7 @@ SELECT
DATA,
data_decoded,
contract_event_xdr,
{{ dbt_utils.generate_surrogate_key(
['transaction_hash','_event_order']
) }} AS fact_contract_events_id,
contract_events_id AS fact_contract_events_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp
FROM

18
models/silver/core/silver__contract_events.sql
View File

@ -74,13 +74,13 @@ WITH pre_final AS (
{% if is_incremental() %}
WHERE
partition_gte_id >= '{{ max_part }}'
AND _inserted_timestamp > '{{ max_is }}'
partition_gte_id >= '2025-05-01'
AND _inserted_timestamp > '2025-05-18'
{% endif %}
{# this is intentionally a rank and not a row_num due to no true PK on the table #}
qualify RANK() over (
PARTITION BY transaction_hash
qualify ROW_NUMBER() over (
PARTITION BY transaction_hash,
contract_event_XDR
ORDER BY
batch_insert_ts DESC,
_inserted_timestamp DESC
@ -106,15 +106,9 @@ SELECT
batch_id,
batch_run_date,
batch_insert_ts,
-- this isn't the order they were executed in but just a random rank to get a PK
ROW_NUMBER() over (
PARTITION BY transaction_hash
ORDER BY
SYSDATE()
) AS _event_order,
_inserted_timestamp,
{{ dbt_utils.generate_surrogate_key(
['transaction_hash','_event_order']
['transaction_hash','contract_event_xdr']
) }} AS contract_events_id,
SYSDATE() AS inserted_timestamp,
SYSDATE() AS modified_timestamp,