Merge branch 'int'
This commit is contained in:
commit
10fad32049
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