From 5e57b632f11699cc19738a7f1e2a8df95d15d012 Mon Sep 17 00:00:00 2001
From: Austin <austin@flipsidecrypto.com>
Date: Tue, 3 Sep 2024 14:33:03 -0400
Subject: [PATCH] change limits

---
 .../core/realtime/streamline__testnet_blocks_realtime.sql   | 6 +++---
 .../streamline__testnet_confirm_blocks_realtime.sql         | 6 +++---
 .../core/realtime/streamline__testnet_receipts_realtime.sql | 6 +++---
 .../core/realtime/streamline__testnet_traces_realtime.sql   | 6 +++---
 .../realtime/streamline__testnet_transactions_realtime.sql  | 6 +++---
 5 files changed, 15 insertions(+), 15 deletions(-)

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"]) }
     ),