fix(teamsbot): reuse existing SSE queue in joinMeeting to prevent stale reference
Co-authored-by: Cursor <cursoragent@cursor.com>
This commit is contained in:
parent
74f6f35ad4
commit
10f172e950
1 changed files with 4 additions and 2 deletions
|
|
@ -716,8 +716,10 @@ class TeamsbotService:
|
||||||
|
|
||||||
interface = interfaceDb.getInterface(self.currentUser, self.mandateId, self.instanceId)
|
interface = interfaceDb.getInterface(self.currentUser, self.mandateId, self.instanceId)
|
||||||
|
|
||||||
# Initialize SSE event queue
|
# Reuse existing SSE event queue if a consumer (SSE generator) already
|
||||||
sessionEvents[sessionId] = asyncio.Queue()
|
# holds a reference; replacing it would strand the SSE stream.
|
||||||
|
if sessionId not in sessionEvents:
|
||||||
|
sessionEvents[sessionId] = asyncio.Queue()
|
||||||
|
|
||||||
try:
|
try:
|
||||||
# Update status to JOINING
|
# Update status to JOINING
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue