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

receipt opt

Browse Source
This commit is contained in:
WHYTEWYLL 2024-07-19 11:20:47 +02:00
parent 55777c7db6
commit 7ef31d630e
2 changed files with 14 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
macros/custom_naming_macros.sql
View File

@ -15,3 +15,9 @@
{% set split_name = node_name.split('__') %}
{{ split_name [1] | trim }}
{%- endmacro %}
{% macro generate_tmp_view_name(model_name) -%}
{% set node_name = model_name.name %}
{% set split_name = node_name.split('__') %}
{{ target.database ~ '.' ~ split_name[0] ~ '.' ~ split_name [1] ~ '__dbt_tmp' | trim }}
{%- endmacro %}

9
models/silver/streamline/silver__streamline_receipts_final.sql
View File

@ -1,12 +1,14 @@
{{ config(
materialized = 'incremental',
incremental_predicates = ["COALESCE(DBT_INTERNAL_DEST.block_timestamp::DATE,'2099-12-31') >= (select min(block_timestamp::DATE) from " ~ generate_tmp_view_name(this) ~ ")"],
incremental_strategy = 'merge',
merge_exclude_columns = ['inserted_timestamp'],
unique_key = 'receipt_object_id',
cluster_by = ['block_timestamp::DATE','_modified_timestamp::DATE', '_partition_by_block_number', ],
post_hook = "ALTER TABLE {{ this }} ADD SEARCH OPTIMIZATION ON EQUALITY(tx_hash,receipt_object_id,receiver_id,signer_id);",
tags = ['receipt_map','scheduled_core'],
full_refresh = False
full_refresh = False,
snowflake_warehouse='DBT_CLOUD_LARGE'
) }}
WITH retry_range AS (
@ -175,3 +177,8 @@ SELECT
'{{ invocation_id }}' AS _invocation_id
FROM
FINAL