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),
 )