diff --git a/dbt_project.yml b/dbt_project.yml index 8f05e4b..3fc0bc2 100644 --- a/dbt_project.yml +++ b/dbt_project.yml @@ -55,6 +55,8 @@ models: +enabled: true core__fact_receipts: +enabled: true + core__ez_actions: + +enabled: true silver: core: +materialized: ephemeral diff --git a/macros/near/near.yaml.sql b/macros/near/near.yaml.sql index d6d5414..dd402eb 100644 --- a/macros/near/near.yaml.sql +++ b/macros/near/near.yaml.sql @@ -53,5 +53,19 @@ sql: | {{ near_live_table_fact_receipts(schema, blockchain, network) | indent(4) -}} +- name: {{ schema -}}.tf_ez_actions + signature: + - [_block_height, INTEGER, The start block height to get the actions from] + - [row_count, INTEGER, The number of rows to fetch] + return_type: + - "TABLE(block_id NUMBER, block_timestamp TIMESTAMP_NTZ, tx_hash STRING, tx_signer BOOLEAN, tx_receiver STRING, tx_gas_used STRING, tx_succeeded NUMBER, tx_fee NUMBER, receipt_id STRING, receipt_receiver_id STRING, receipt_signer_id STRING, receipt_predecessor_id STRING, receipt_succeeded BOOLEAN, receipt_gas_burnt NUMBER, receipt_status_value OBJECT, is_delegated NUMBER, action_index BOOLEAN, action_name STRING, action_data OBJECT, action_gas_price NUMBER, _partition_by_block_number NUMBER, actions_id STRING, inserted_timestamp TIMESTAMP_NTZ, modified_timestamp TIMESTAMP_NTZ, _invocation_id STRING)" + options: | + NOT NULL + RETURNS NULL ON NULL INPUT + VOLATILE + COMMENT = $$Returns decoded action details for blocks starting from a given height. Fetches actions for the specified number of blocks.$$ + sql: | + {{ near_live_table_ez_actions(schema, blockchain, network) | indent(4) -}} + {%- endmacro -%} diff --git a/macros/near/near_live_table_abstractions.sql b/macros/near/near_live_table_abstractions.sql index e7e6f9a..eace7b2 100644 --- a/macros/near/near_live_table_abstractions.sql +++ b/macros/near/near_live_table_abstractions.sql @@ -154,4 +154,7 @@ FROM {{raw_blocks}} {{ near_live_table_fact_receipts }} {% endmacro %} - +{% macro near_live_table_ez_actions(schema, blockchain, network) %} + {%- set near_live_table_ez_actions = get_rendered_model('livequery_models', 'near_ez_actions', schema, blockchain, network) -%} + {{ near_live_table_ez_actions }} +{% endmacro %} diff --git a/models/deploy/near/near__mainnet.sql b/models/deploy/near/near__mainnet.sql index c8ff987..9a3241a 100644 --- a/models/deploy/near/near__mainnet.sql +++ b/models/deploy/near/near__mainnet.sql @@ -10,6 +10,8 @@ -- depends_on: {{ ref('livequery_models', 'bronze__FR_transactions') }} -- depends_on: {{ ref('near_models','core__fact_receipts') }} -- depends_on: {{ ref('near_models','silver__receipts_final') }} +-- depends_on: {{ ref('near_models', 'core__ez_actions') }} + {%- set configs = [ config_near_high_level_abstractions ] -%} diff --git a/models/overrides/near/gold/near_ez_actions.sql b/models/overrides/near/gold/near_ez_actions.sql new file mode 100644 index 0000000..03fb3b3 --- /dev/null +++ b/models/overrides/near/gold/near_ez_actions.sql @@ -0,0 +1,12 @@ +-- depends_on: {{ ref('livequery_models', 'bronze__transactions') }} +-- depends_on: {{ ref('livequery_models', 'bronze__FR_transactions') }} +-- depends_on: {{ ref('livequery_models','bronze__transactions') }} +-- depends_on: {{ ref('livequery_models','bronze__FR_transactions') }} +-- depends_on: {{ ref('livequery_models','bronze__blocks') }} +-- depends_on: {{ ref('livequery_models','bronze__FR_blocks') }} +-- depends_on: {{ ref('near_models', 'silver__blocks_v2') }} +-- depends_on: {{ ref('near_models', 'silver__transactions_v2') }} +-- depends_on: {{ ref('near_models', 'silver__transactions_final') }} +-- depends_on: {{ ref('near_models', 'silver__receipts_final')}} + +SELECT * FROM {{ ref('near_models','core__ez_actions')}}