diff --git a/modules/features/teamsbot/service.py b/modules/features/teamsbot/service.py
index 164e8703..e1c2745a 100644
--- a/modules/features/teamsbot/service.py
+++ b/modules/features/teamsbot/service.py
@@ -55,10 +55,11 @@ _sessionEvents: Dict[str, asyncio.Queue] = {}
 
 
 async def _emitSessionEvent(sessionId: str, eventType: str, data: Any):
-    """Emit an event to the session's SSE stream."""
-    eventQueue = _sessionEvents.get(sessionId)
-    if eventQueue:
-        await eventQueue.put({"type": eventType, "data": data, "timestamp": getIsoTimestamp()})
+    """Emit an event to the session's SSE stream.
+    Creates the queue on-demand so events are never silently dropped."""
+    if sessionId not in _sessionEvents:
+        _sessionEvents[sessionId] = asyncio.Queue()
+    await _sessionEvents[sessionId].put({"type": eventType, "data": data, "timestamp": getIsoTimestamp()})
 
 
 class TeamsbotService: