hardcoding v2 (#294)

This commit is contained in:
WHYTEWYLL 2024-03-14 18:34:20 -06:00 committed by GitHub
parent e90fb88156
commit 131146940b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
9 changed files with 12 additions and 12 deletions

View File

@ -2,7 +2,7 @@
materialized = "view",
post_hook = fsc_utils.if_data_call_function_v2(
func = 'udf_bulk_grpc',
target = "{{this.schema}}.{{this.identifier}}",
target = "streamline.{{this.identifier}}",
params = {
"node_url":"access-001.mainnet17.nodes.onflow.org:9000",
"external_table": "transaction_results_mainnet_17",

View File

@ -2,7 +2,7 @@
materialized = "view",
post_hook = fsc_utils.if_data_call_function_v2(
func = 'udf_bulk_grpc',
target = "{{this.schema}}.{{this.identifier}}",
target = "streamline.{{this.identifier}}",
params = {
"node_url":"access-001.mainnet18.nodes.onflow.org:9000",
"external_table": "transaction_results_mainnet_18",

View File

@ -2,7 +2,7 @@
materialized = "view",
post_hook = fsc_utils.if_data_call_function_v2(
func = 'udf_bulk_grpc',
target = "{{this.schema}}.{{this.identifier}}",
target = "streamline.{{this.identifier}}",
params = {
"node_url":"access-001.mainnet19.nodes.onflow.org:9000",
"external_table": "transaction_results_mainnet_19",

View File

@ -2,7 +2,7 @@
materialized = "view",
post_hook = fsc_utils.if_data_call_function_v2(
func = 'udf_bulk_grpc',
target = "{{this.schema}}.{{this.identifier}}",
target = "streamline.{{this.identifier}}",
params = {
"node_url":"access-001.mainnet22.nodes.onflow.org:9000",
"external_table": "transaction_results_mainnet_22",

View File

@ -1,8 +1,8 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet14.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_14', 'sql_limit', '500000', 'producer_batch_size','300000', 'worker_batch_size','100', 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
func = "streamline.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet14.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_14', 'sql_limit', '500000', 'producer_batch_size','300000', 'worker_batch_size','100', 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "streamline.{{this.identifier}}"
)
) }}

View File

@ -1,8 +1,8 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet15.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_15','sql_limit', '500000', 'producer_batch_size','400000', 'worker_batch_size','100', 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
func = "streamline.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet15.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_15','sql_limit', '500000', 'producer_batch_size','400000', 'worker_batch_size','100', 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "streamline.{{this.identifier}}"
)
) }}

View File

@ -1,8 +1,8 @@
{{ config (
materialized = "view",
post_hook = if_data_call_function(
func = "{{this.schema}}.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet16.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_16', 'sql_limit', '500000', 'producer_batch_size','200000', 'worker_batch_size','100', 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "{{this.schema}}.{{this.identifier}}"
func = "streamline.udf_bulk_grpc(object_construct('sql_source', '{{this.identifier}}','node_url','access-001.mainnet16.nodes.onflow.org:9000','external_table', 'transaction_results_mainnet_16', 'sql_limit', '500000', 'producer_batch_size','200000', 'worker_batch_size','100', 'batch_call_limit', {{var('batch_call_limit','1')}}))",
target = "streamline.{{this.identifier}}"
)
) }}

View File

@ -2,7 +2,7 @@
materialized = "view",
post_hook = fsc_utils.if_data_call_function_v2(
func = 'udf_bulk_grpc',
target = "{{this.schema}}.{{this.identifier}}",
target = "streamline.{{this.identifier}}",
params = {
"node_url":"access-001.mainnet18.nodes.onflow.org:9000",
"external_table": "transactions_mainnet_18",

View File

@ -2,7 +2,7 @@
materialized = "view",
post_hook = fsc_utils.if_data_call_function_v2(
func = 'udf_bulk_grpc',
target = "{{this.schema}}.{{this.identifier}}",
target = "streamline.{{this.identifier}}",
params = {
"node_url":"access-001.mainnet19.nodes.onflow.org:9000",
"external_table": "transactions_mainnet_19",