diff --git a/models/streamline/core/realtime/streamline__testnet_blocks_realtime.sql b/models/streamline/core/realtime/streamline__testnet_blocks_realtime.sql index cc3c4f1..e0aa2de 100644 --- a/models/streamline/core/realtime/streamline__testnet_blocks_realtime.sql +++ b/models/streamline/core/realtime/streamline__testnet_blocks_realtime.sql @@ -4,9 +4,9 @@ func = 'streamline.udf_bulk_rest_api_v2', target = "{{this.schema}}.{{this.identifier}}", params ={ "external_table" :"testnet_blocks", - "sql_limit" :"20000", - "producer_batch_size" :"5000", - "worker_batch_size" :"2000", + "sql_limit" :"12000", + "producer_batch_size" :"12000", + "worker_batch_size" :"800", "sql_source" :"{{this.identifier}}" } ), tags = ['streamline_testnet_realtime'] diff --git a/models/streamline/core/realtime/streamline__testnet_confirm_blocks_realtime.sql b/models/streamline/core/realtime/streamline__testnet_confirm_blocks_realtime.sql index 6593978..33d3d9d 100644 --- a/models/streamline/core/realtime/streamline__testnet_confirm_blocks_realtime.sql +++ b/models/streamline/core/realtime/streamline__testnet_confirm_blocks_realtime.sql @@ -4,9 +4,9 @@ func = 'streamline.udf_bulk_rest_api_v2', target = "{{this.schema}}.{{this.identifier}}", params ={ "external_table" :"testnet_confirm_blocks", - "sql_limit" :"20000", - "producer_batch_size" :"5000", - "worker_batch_size" :"2000", + "sql_limit" :"12000", + "producer_batch_size" :"12000", + "worker_batch_size" :"800", "sql_source" :"{{this.identifier}}" } ), tags = ['streamline_testnet_realtime'] diff --git a/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql b/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql index 44ad1c0..ce3810b 100644 --- a/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql +++ b/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql @@ -4,9 +4,9 @@ func = 'streamline.udf_bulk_rest_api_v2', target = "{{this.schema}}.{{this.identifier}}", params ={ "external_table" :"testnet_receipts", - "sql_limit" :"20000", - "producer_batch_size" :"5000", - "worker_batch_size" :"2000", + "sql_limit" :"12000", + "producer_batch_size" :"12000", + "worker_batch_size" :"800", "sql_source" :"{{this.identifier}}", "exploded_key": tojson(["result"]) } ), diff --git a/models/streamline/core/realtime/streamline__testnet_traces_realtime.sql b/models/streamline/core/realtime/streamline__testnet_traces_realtime.sql index 2b141e0..f73869a 100644 --- a/models/streamline/core/realtime/streamline__testnet_traces_realtime.sql +++ b/models/streamline/core/realtime/streamline__testnet_traces_realtime.sql @@ -4,9 +4,9 @@ func = 'streamline.udf_bulk_rest_api_v2', target = "{{this.schema}}.{{this.identifier}}", params ={ "external_table" :"testnet_traces", - "sql_limit" :"20000", - "producer_batch_size" :"5000", - "worker_batch_size" :"2000", + "sql_limit" :"12000", + "producer_batch_size" :"12000", + "worker_batch_size" :"800", "sql_source" :"{{this.identifier}}", "exploded_key": tojson(["result"]) } ), diff --git a/models/streamline/core/realtime/streamline__testnet_transactions_realtime.sql b/models/streamline/core/realtime/streamline__testnet_transactions_realtime.sql index 8ea2f6d..1690fbc 100644 --- a/models/streamline/core/realtime/streamline__testnet_transactions_realtime.sql +++ b/models/streamline/core/realtime/streamline__testnet_transactions_realtime.sql @@ -4,9 +4,9 @@ func = 'streamline.udf_bulk_rest_api_v2', target = "{{this.schema}}.{{this.identifier}}", params ={ "external_table" :"testnet_transactions", - "sql_limit" :"20000", - "producer_batch_size" :"5000", - "worker_batch_size" :"2000", + "sql_limit" :"12000", + "producer_batch_size" :"12000", + "worker_batch_size" :"800", "sql_source" :"{{this.identifier}}", "exploded_key": tojson(["result.transactions"]) } ),