From 281de1dadb634101744934cd6f605a91221a2fe4 Mon Sep 17 00:00:00 2001 From: ali Date: Wed, 8 Oct 2025 12:13:09 +0530 Subject: [PATCH] UN-2857 [MISC] Fix Redis unacked hash memory leak in log consumer worker Added write_only=True parameter to KombuManager in log_consumer worker to prevent accumulation of unacked messages in Redis. --- workers/log_consumer/tasks.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/workers/log_consumer/tasks.py b/workers/log_consumer/tasks.py index e30d523f2f..93c44398a3 100644 --- a/workers/log_consumer/tasks.py +++ b/workers/log_consumer/tasks.py @@ -37,7 +37,7 @@ async_mode="threading", logger=False, engineio_logger=False, - client_manager=socketio.KombuManager(url=socket_io_manager_url), + client_manager=socketio.KombuManager(url=socket_io_manager_url, write_only=True), )