From 7e188e9d00ea3785f10f82f62f4146bf3fab1462 Mon Sep 17 00:00:00 2001 From: shah Date: Mon, 15 Sep 2025 23:06:08 -0700 Subject: [PATCH] add QN node_url to sl testnet model --- Makefile | 8 ++++++++ .../streamline__get_testnet_blocks_realtime.sql | 2 +- 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/Makefile b/Makefile index ae3c150..750ba92 100644 --- a/Makefile +++ b/Makefile @@ -119,3 +119,11 @@ bronze: --vars '{"STREAMLINE_USE_DEV_FOR_EXTERNAL_TABLES": True}' \ --profiles-dir ~/.dbt \ --target $(DBT_TARGET) + +blocks_testnet: + dbt run \ + --vars '{"STREAMLINE_INVOKE_STREAMS":True, "STREAMLINE_USE_DEV_FOR_EXTERNAL_TABLES": True}' \ + -m 1+models/streamline/core/realtime_testnet/streamline__get_testnet_blocks_realtime.sql \ + --profile flow \ + --target $(DBT_TARGET) \ + --profiles-dir ~/.dbt \ No newline at end of file diff --git a/models/streamline/core/realtime_testnet/streamline__get_testnet_blocks_realtime.sql b/models/streamline/core/realtime_testnet/streamline__get_testnet_blocks_realtime.sql index 352ad23..ae3c6d4 100644 --- a/models/streamline/core/realtime_testnet/streamline__get_testnet_blocks_realtime.sql +++ b/models/streamline/core/realtime_testnet/streamline__get_testnet_blocks_realtime.sql @@ -1,7 +1,7 @@ {{ config ( materialized = "view", post_hook = if_data_call_function( - func = "{{this.schema}}.udf_bulk_grpc_v2(object_construct('sql_source', '{{this.identifier}}','node_url','access.devnet.nodes.onflow.org:9000','external_table', 'testnet_blocks_v2', 'sql_limit', {{var('sql_limit','15000')}}, 'producer_batch_size', {{var('producer_batch_size','5000')}}, 'worker_batch_size', {{var('worker_batch_size','500')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))", + func = "{{this.schema}}.udf_bulk_grpc_v2(object_construct('sql_source', '{{this.identifier}}','node_url','late-multi-patina.flow-testnet.quiknode.pro:8999','external_table', 'testnet_blocks_v2', 'sql_limit', {{var('sql_limit','15000')}}, 'producer_batch_size', {{var('producer_batch_size','5000')}}, 'worker_batch_size', {{var('worker_batch_size','500')}}, 'batch_call_limit', {{var('batch_call_limit','1')}}))", target = "{{this.schema}}.{{this.identifier}}" ), tags = ['streamline_realtime_testnet']