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

Calling task_done when reading the audio from the queue.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-09-23 08:04:06 -03:00
parent 8bf6a4c66f
commit 7c569b3863
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/transports/base_output.py
View File

@@ -659,6 +659,7 @@ class BaseOutputTransport(FrameProcessor):
self._audio_queue.get(), timeout=vad_stop_secs self._audio_queue.get(), timeout=vad_stop_secs
) )
yield frame yield frame
self._audio_queue.task_done()
except asyncio.TimeoutError: except asyncio.TimeoutError:
# Notify the bot stopped speaking upstream if necessary. # Notify the bot stopped speaking upstream if necessary.
await self._bot_stopped_speaking() await self._bot_stopped_speaking()
@@ -673,6 +674,7 @@ class BaseOutputTransport(FrameProcessor):
frame.audio = await self._mixer.mix(frame.audio) frame.audio = await self._mixer.mix(frame.audio)
last_frame_time = time.time() last_frame_time = time.time()
yield frame yield frame
self._audio_queue.task_done()
except asyncio.QueueEmpty: except asyncio.QueueEmpty:
# Notify the bot stopped speaking upstream if necessary. # Notify the bot stopped speaking upstream if necessary.
diff_time = time.time() - last_frame_time diff_time = time.time() - last_frame_time