mirror of
https://github.com/FlipsideCrypto/flow-models.git
synced 2026-02-06 13:41:55 +00:00
792f11599f
* txs final and upd streamline tests w 1 hr inserted timestamp buffer * copy silver models into silver_cw dir * txs final, events model, curated model _s copies * add pending col to txs final * test config for pending_result_response * add coalesce to tx id in txs final * rem tests on inserted timestamp * uppercase gap test vars * add retry for null block timestamp and del mainnet23 filter from events * address adj append 0x, add network ver to blocks, etc * upd coalesce on events data * saving event migration test, disabled * req changes * upd txs final ingested logic
47 lines
869 B
SQL
47 lines
869 B
SQL
{{ config(
|
|
enabled = False
|
|
) }}
|
|
|
|
WITH dev_sample AS (
|
|
|
|
SELECT
|
|
*
|
|
FROM
|
|
flow_dev.silver.streamline_events
|
|
WHERE
|
|
block_height >= 55114467
|
|
),
|
|
prod_sample AS (
|
|
SELECT
|
|
*
|
|
FROM
|
|
flow.silver.events_final
|
|
WHERE
|
|
block_height >= 55114467
|
|
),
|
|
dcheck AS (
|
|
SELECT
|
|
d.tx_id,
|
|
d.block_height,
|
|
d.event_id,
|
|
d.event_contract = p.event_contract AS event_contract_match,
|
|
d.event_type = p.event_type AS event_type_match,
|
|
d.event_data AS event_data_s,
|
|
p.event_data AS event_data_cw,
|
|
d.event_data = p.event_data AS event_data_match
|
|
FROM
|
|
dev_sample d
|
|
LEFT JOIN prod_sample p USING (
|
|
tx_id,
|
|
event_index
|
|
)
|
|
WHERE
|
|
p.tx_id IS NOT NULL
|
|
)
|
|
SELECT
|
|
*
|
|
FROM
|
|
dcheck
|
|
WHERE
|
|
NOT event_data_match
|