From 16e0fa9c7a3a2f57eb079685f0781ce8f995d457 Mon Sep 17 00:00:00 2001 From: WHYTEWYLL <49686519+WHYTEWYLL@users.noreply.github.com> Date: Thu, 14 Mar 2024 18:57:39 -0600 Subject: [PATCH] v2 --- macros/streamline/utils.sql | 38 +++++++++++++++++++ ...transaction_results_history_mainnet_17.sql | 2 +- ...transaction_results_history_mainnet_18.sql | 2 +- ...transaction_results_history_mainnet_19.sql | 2 +- ...transaction_results_history_mainnet_22.sql | 2 +- ...ine__get_batch_transactions_mainnet_18.sql | 2 +- ...ine__get_batch_transactions_mainnet_19.sql | 2 +- 7 files changed, 44 insertions(+), 6 deletions(-) diff --git a/macros/streamline/utils.sql b/macros/streamline/utils.sql index ac23d7b..1e6fc56 100644 --- a/macros/streamline/utils.sql +++ b/macros/streamline/utils.sql @@ -46,4 +46,42 @@ SELECT _utils.UDF_REGISTER_SECRET(REQUEST_ID, _utils.UDF_WHOAMI(), KEY) +{% endmacro %} + + +{% macro if_data_call_function_v2( + func, + target, + params + ) %} + {% if var( + "STREAMLINE_INVOKE_STREAMS" + ) %} + {% if execute %} + {{ log( + "Running macro `if_data_call_function`: Calling udf " ~ func ~ " with params: \n" ~ params | tojson(indent=2) ~ "\n on " ~ target, + True + ) }} + {% endif %} + SELECT + {{ func }}( parse_json($${{ params | tojson }}$$) ) + WHERE + EXISTS( + SELECT + 1 + FROM + {{ target }} + LIMIT + 1 + ) + {% else %} + {% if execute %} + {{ log( + "Running macro `if_data_call_function`: NOOP", + False + ) }} + {% endif %} + SELECT + NULL + {% endif %} {% endmacro %} \ No newline at end of file diff --git a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_17.sql b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_17.sql index 67e5932..90a4268 100644 --- a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_17.sql +++ b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_17.sql @@ -1,6 +1,6 @@ {{ config ( materialized = "view", - post_hook = fsc_utils.if_data_call_function_v2( + post_hook = if_data_call_function_v2( func = 'udf_bulk_grpc', target = "streamline.{{this.identifier}}", params = { diff --git a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_18.sql b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_18.sql index 9ba1d72..d6e0af5 100644 --- a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_18.sql +++ b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_18.sql @@ -1,6 +1,6 @@ {{ config ( materialized = "view", - post_hook = fsc_utils.if_data_call_function_v2( + post_hook = if_data_call_function_v2( func = 'udf_bulk_grpc', target = "streamline.{{this.identifier}}", params = { diff --git a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_19.sql b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_19.sql index 6184c4c..0f6ba66 100644 --- a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_19.sql +++ b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_19.sql @@ -1,6 +1,6 @@ {{ config ( materialized = "view", - post_hook = fsc_utils.if_data_call_function_v2( + post_hook = if_data_call_function_v2( func = 'udf_bulk_grpc', target = "streamline.{{this.identifier}}", params = { diff --git a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_22.sql b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_22.sql index 1fe41a5..1564b53 100644 --- a/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_22.sql +++ b/models/silver/streamline/core/history/transaction_results/batch/streamline__get_batch_transaction_results_history_mainnet_22.sql @@ -1,6 +1,6 @@ {{ config ( materialized = "view", - post_hook = fsc_utils.if_data_call_function_v2( + post_hook = if_data_call_function_v2( func = 'udf_bulk_grpc', target = "streamline.{{this.identifier}}", params = { diff --git a/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_18.sql b/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_18.sql index f7afb80..c869e0a 100644 --- a/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_18.sql +++ b/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_18.sql @@ -1,6 +1,6 @@ {{ config ( materialized = "view", - post_hook = fsc_utils.if_data_call_function_v2( + post_hook = if_data_call_function_v2( func = 'udf_bulk_grpc', target = "streamline.{{this.identifier}}", params = { diff --git a/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_19.sql b/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_19.sql index e3ae813..33a853f 100644 --- a/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_19.sql +++ b/models/silver/streamline/core/history/transactions/batch/streamline__get_batch_transactions_mainnet_19.sql @@ -1,6 +1,6 @@ {{ config ( materialized = "view", - post_hook = fsc_utils.if_data_call_function_v2( + post_hook = if_data_call_function_v2( func = 'udf_bulk_grpc', target = "streamline.{{this.identifier}}", params = {