From 30cff653ea600d2922c8dce76dbf66d0bae54c5f Mon Sep 17 00:00:00 2001 From: Austin <93135983+austinFlipside@users.noreply.github.com> Date: Thu, 21 Nov 2024 17:44:36 -0500 Subject: [PATCH] limit (#229) --- macros/decoder/decoded_logs_history.sql | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/macros/decoder/decoded_logs_history.sql b/macros/decoder/decoded_logs_history.sql index 91b064c..9310446 100644 --- a/macros/decoder/decoded_logs_history.sql +++ b/macros/decoder/decoded_logs_history.sql @@ -4,7 +4,7 @@ "sql_limit": var("DECODED_LOGS_HISTORY_SQL_LIMIT", 7500000), "producer_batch_size": var("DECODED_LOGS_HISTORY_PRODUCER_BATCH_SIZE", 400000), "worker_batch_size": var("DECODED_LOGS_HISTORY_WORKER_BATCH_SIZE", 100000), - "producer_limit_size": var("DECODED_LOGS_HISTORY_WORKER_BATCH_SIZE", 100000) + "producer_limit_size": var("DECODED_LOGS_HISTORY_WORKER_BATCH_SIZE", 5000000) } -%} {% set wait_time = var("DECODED_LOGS_HISTORY_WAIT_TIME", 60) %}