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

DailyTransport: make sure we can write audio frames to destination

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-05-01 05:15:54 -07:00
parent 458fddfb48
commit afe1f0df8c
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -392,10 +392,11 @@ class DailyTransportClient(EventHandler):
future = self._get_event_loop().create_future() future = self._get_event_loop().create_future()
if not destination and self._mic: if not destination and self._mic:
self._mic.write_frames(frames, completion=completion_callback(future)) self._mic.write_frames(frames, completion=completion_callback(future))
elif destination: elif destination and destination in self._audio_sources:
source = self._audio_sources[destination] source = self._audio_sources[destination]
source.write_frames(frames, completion=completion_callback(future)) source.write_frames(frames, completion=completion_callback(future))
else: else:
logger.warning(f"{self} unable to write audio frames to destination [{destination}]")
future.set_result(None) future.set_result(None)
await future await future