From a563d77bbbb510603a4a605472b95b392e8124ba Mon Sep 17 00:00:00 2001 From: xiuy001 Date: Tue, 12 Dec 2023 18:08:02 -0500 Subject: [PATCH] added partition_scale to the dbt model --- .../silver/core/realtime/streamline__flat_traces_realtime.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/models/streamline/silver/core/realtime/streamline__flat_traces_realtime.sql b/models/streamline/silver/core/realtime/streamline__flat_traces_realtime.sql index 2b690bb..f620e4b 100644 --- a/models/streamline/silver/core/realtime/streamline__flat_traces_realtime.sql +++ b/models/streamline/silver/core/realtime/streamline__flat_traces_realtime.sql @@ -1,7 +1,7 @@ {{ config ( materialized = "view", post_hook = if_data_call_function( - func = "{{this.schema}}.udf_json_rpc(object_construct('batch_call','non_batch_call', 'sql_source', '{{this.identifier}}', 'external_table', 'flat_traces', 'partition_scale','-2', 'recursive', 'true', 'exploded_key','[\"result\", \"calls\"]', 'method', 'debug_traceBlockByNumber', 'producer_batch_size',2000, 'producer_limit_size', 2000000, 'worker_batch_size',200))", + func = "{{this.schema}}.udf_json_rpc(object_construct('batch_call','non_batch_call', 'sql_source', '{{this.identifier}}', 'external_table', 'flat_traces', 'partition_scale','-2', 'recursive', 'true', 'exploded_key','[\"result\", \"calls\"]', 'method', 'debug_traceBlockByNumber', 'producer_batch_size',100, 'producer_limit_size', 2000000, 'worker_batch_size',10))", target = "{{this.schema}}.{{this.identifier}}" ), tags = ['streamline_core_realtime']