modules/features/teamsbot/service.py

@@ -716,10 +716,8 @@ class TeamsbotService:
 
         interface = interfaceDb.getInterface(self.currentUser, self.mandateId, self.instanceId)
 
-        # Reuse existing SSE event queue if a consumer (SSE generator) already
+        # Initialize SSE event queue
-        # holds a reference; replacing it would strand the SSE stream.
+        sessionEvents[sessionId] = asyncio.Queue()
-        if sessionId not in sessionEvents:
-            sessionEvents[sessionId] = asyncio.Queue()
 
         try:
             # Update status to JOINING