UN-2857 [MISC] Fix Redis unacked hash memory leak in log consumer worker (#1566)

Added write_only=True parameter to KombuManager in log_consumer worker to prevent accumulation of unacked messages in Redis.
2025-10-10 10:25:12 +05:30
parent d7113fcf80
commit 435759b12f
1 changed files with 1 additions and 1 deletions
--- a/workers/log_consumer/tasks.py
+++ b/workers/log_consumer/tasks.py
@@ -37,7 +37,7 @@ sio = socketio.Server(
    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),
 )