modules/features/teamsbot/service.py

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