From 2cfcac88ff76d2d2035d8f3b8856492018d4ff1b Mon Sep 17 00:00:00 2001
From: drethereum <71602799+drethereum@users.noreply.github.com>
Date: Mon, 22 Jul 2024 13:51:05 -0600
Subject: [PATCH] worker size (#188)

---
 .../realtime/streamline__qn_getBlockWithReceipts_realtime.sql   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/models/streamline/silver/core/realtime/streamline__qn_getBlockWithReceipts_realtime.sql b/models/streamline/silver/core/realtime/streamline__qn_getBlockWithReceipts_realtime.sql
index bbaa34d..8a216fe 100644
--- a/models/streamline/silver/core/realtime/streamline__qn_getBlockWithReceipts_realtime.sql
+++ b/models/streamline/silver/core/realtime/streamline__qn_getBlockWithReceipts_realtime.sql
@@ -1,7 +1,7 @@
 {{ config (
     materialized = "view",
     post_hook = if_data_call_function(
-        func = "{{this.schema}}.udf_bulk_json_rpc(object_construct('sql_source', '{{this.identifier}}', 'external_table', 'qn_getBlockWithReceipts', 'sql_limit', {{var('sql_limit','100000')}}, 'producer_batch_size', {{var('producer_batch_size','100000')}}, 'worker_batch_size', {{var('worker_batch_size','100000')}}, 'batch_call_limit', {{var('batch_call_limit','3')}}))",
+        func = "{{this.schema}}.udf_bulk_json_rpc(object_construct('sql_source', '{{this.identifier}}', 'external_table', 'qn_getBlockWithReceipts', 'sql_limit', {{var('sql_limit','100000')}}, 'producer_batch_size', {{var('producer_batch_size','100000')}}, 'worker_batch_size', {{var('worker_batch_size','50000')}}, 'batch_call_limit', {{var('batch_call_limit','3')}}))",
         target = "{{this.schema}}.{{this.identifier}}"
     ),
     tags = ['streamline_core_realtime']