diff --git a/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql b/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql index 408ca13..09b18f0 100644 --- a/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql +++ b/models/streamline/core/realtime/streamline__testnet_receipts_realtime.sql @@ -5,8 +5,8 @@ target = "{{this.schema}}.{{this.identifier}}", params ={ "external_table" :"testnet_receipts", "sql_limit" :"3600", - "producer_batch_size" :"3600", - "worker_batch_size" :"3600", + "producer_batch_size" :"1800", + "worker_batch_size" :"1800", "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 cb73be9..8f26736 100644 --- a/models/streamline/core/realtime/streamline__testnet_traces_realtime.sql +++ b/models/streamline/core/realtime/streamline__testnet_traces_realtime.sql @@ -5,8 +5,8 @@ target = "{{this.schema}}.{{this.identifier}}", params ={ "external_table" :"testnet_traces", "sql_limit" :"3600", - "producer_batch_size" :"3600", - "worker_batch_size" :"3600", + "producer_batch_size" :"1800", + "worker_batch_size" :"1800", "sql_source" :"{{this.identifier}}", "exploded_key": tojson(["result"]) } ),