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

DailyTransport: make sure we have a client before joining/leaving

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-08-27 11:11:15 -07:00
parent 74af2b6aa4
commit 41d40f9a11
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -640,6 +640,9 @@ class DailyTransportClient(EventHandler):
async def _join(self): async def _join(self):
"""Execute the actual room join operation.""" """Execute the actual room join operation."""
if not self._client:
return
future = self._get_event_loop().create_future() future = self._get_event_loop().create_future()
camera_enabled = self._params.video_out_enabled and self._params.camera_out_enabled camera_enabled = self._params.video_out_enabled and self._params.camera_out_enabled
@@ -731,6 +734,9 @@ class DailyTransportClient(EventHandler):
async def _leave(self): async def _leave(self):
"""Execute the actual room leave operation.""" """Execute the actual room leave operation."""
if not self._client:
return
future = self._get_event_loop().create_future() future = self._get_event_loop().create_future()
self._client.leave(completion=completion_callback(future)) self._client.leave(completion=completion_callback(future))
return await asyncio.wait_for(future, timeout=10) return await asyncio.wait_for(future, timeout=10)