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

transports(daily): avoid canceling task more than once

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-01-24 19:29:35 -08:00
parent 6bca8396d3
commit e48c0e52ef
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -476,7 +476,9 @@ class DailyTransportClient(EventHandler):
return await asyncio.wait_for(future, timeout=10) return await asyncio.wait_for(future, timeout=10)
async def cleanup(self): async def cleanup(self):
await cancel_task(self._callback_task) if self._callback_task:
await cancel_task(self._callback_task)
self._callback_task = None
# Make sure we don't block the event loop in case `client.release()` # Make sure we don't block the event loop in case `client.release()`
# takes extra time. # takes extra time.
await self._loop.run_in_executor(self._executor, self._cleanup) await self._loop.run_in_executor(self._executor, self._cleanup)