wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

transports(daily): cancel messages task when canceling

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2024-10-15 17:47:12 -07:00
parent 04da51c7d8
commit 713dcb7a4d
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/pipecat/transports/services/daily.py
View File

@@ -740,13 +740,17 @@ class DailyOutputTransport(BaseOutputTransport):
self._messages_task.cancel() self._messages_task.cancel()
await self._messages_task await self._messages_task
self._messages_task = None self._messages_task = None
self._messages_task = None
# Leave the room. # Leave the room.
await self._client.leave() await self._client.leave()
async def cancel(self, frame: CancelFrame): async def cancel(self, frame: CancelFrame):
# Parent stop. # Parent stop.
await super().cancel(frame) await super().cancel(frame)
# Cancel messages task
if self._messages_task:
self._messages_task.cancel()
await self._messages_task
self._messages_task = None
# Leave the room. # Leave the room.
await self._client.leave() await self._client.leave()