diff --git a/events/sse.py b/events/sse.py
index d27a14a..c6c93d3 100644
--- a/events/sse.py
+++ b/events/sse.py
@@ -13,7 +13,7 @@ logger = logging.getLogger(__name__)
 
 manager = Manager()
 # Maps user_id → dict of {connection_id: queue}
-user_queues: Dict[str, Dict[str, queue.Queue]] = {}
+user_queues = manager.dict()  # Shared across all Gunicorn workers
 logging.basicConfig(level=logging.INFO)