bsc-models/macros/dbt/incremental_predicates.sql
Matt Romano fe785ab19e
AN-5339/bsc-standarization (#310)
* log and timestamp updates + formatted

* logs refs

* update logs stuff

* ref updates fix nfts

* add tx_succeeded and trace

* docs n gold

* log updates

* curated fixes

* revert deocded logs

* nft fixes

* add yml updates

* add decoded log backstops

* native fix

* revert lookback

* decoded table

* column order

* add predicates macro

* tx_succeeded

* add bridge status back
2025-02-11 13:44:08 -08:00

22 lines
724 B
SQL

{% macro standard_predicate(
input_column = 'block_number'
) -%}
{%- set database_name = target.database -%}
{%- set schema_name = generate_schema_name(
node = model
) -%}
{%- set table_name = generate_alias_name(
node = model
) -%}
{%- set tmp_table_name = table_name ~ '__dbt_tmp' -%}
{%- set full_table_name = database_name ~ '.' ~ schema_name ~ '.' ~ table_name -%}
{%- set full_tmp_table_name = database_name ~ '.' ~ schema_name ~ '.' ~ tmp_table_name -%}
{{ full_table_name }}.{{ input_column }} >= (
SELECT
MIN(
{{ input_column }}
)
FROM
{{ full_tmp_table_name }}
)
{%- endmacro %}