From a27307263f9afaeef09c6f1d8c99010549122040 Mon Sep 17 00:00:00 2001 From: patrick-motsch Date: Tue, 17 Feb 2026 23:44:12 +0100 Subject: [PATCH] fix: create SSE event queue on-demand so transcript/chat events are never silently dropped Co-authored-by: Cursor --- modules/features/teamsbot/service.py | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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: