mirror of
https://github.com/FlipsideCrypto/solana-models.git
synced 2026-02-06 13:16:44 +00:00
4860722d32
* new SCD logic for token owners * test workflow * test workflow * test workflow * fix account ownership recording change event when no change event * update logic to run off intermediate upstream, modify merge strategy * reprocess out of order events, get last known state of first reprocessed record * temp look at prod table hardcoded * add end_block_id to cluster key * add predicate * try with diff cluster key and simple min value predicate * delete test workflow * remove hardcoded values, add check for if incremental has 0 rows * add schema and tests * cleanup and formatting, remove hardcoded value
29 lines
934 B
SQL
29 lines
934 B
SQL
{% macro generate_schema_name(
|
|
custom_schema_name = none,
|
|
node = none
|
|
) -%}
|
|
{% set node_name = node.name %}
|
|
{% set split_name = node_name.split('__') %}
|
|
{{ split_name [0] | trim }}
|
|
{%- endmacro %}
|
|
|
|
{% macro generate_alias_name(
|
|
custom_alias_name = none,
|
|
node = none
|
|
) -%}
|
|
{% set node_name = node.name %}
|
|
{% 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 %}
|
|
|
|
{% macro generate_view_name(model_name) -%}
|
|
{% set node_name = model_name.name %}
|
|
{% set split_name = node_name.split('__') %}
|
|
{{ target.database ~ '.' ~ split_name[0] ~ '.' ~ split_name [1] | trim }}
|
|
{%- endmacro %} |