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

Adding fallback in case the clock queue is not drained.

Browse Source
This commit is contained in:
filipi87
2026-03-27 18:18:28 -03:00
parent 265540b8ce
commit de1fd67b2d
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -834,7 +834,13 @@ class BaseOutputTransport(FrameProcessor):
if isinstance(frame, TTSStoppedFrame) and self._clock_flush_event is not None: if isinstance(frame, TTSStoppedFrame) and self._clock_flush_event is not None:
logger.debug(f"{self._transport} audio queue signalling clock queue flush") logger.debug(f"{self._transport} audio queue signalling clock queue flush")
self._clock_flush_event.set() self._clock_flush_event.set()
await self._clock_drained_event.wait() try:
await asyncio.wait_for(self._clock_drained_event.wait(), timeout=BOT_VAD_STOP_FALLBACK_SECS)
except asyncio.TimeoutError:
logger.warning(
f"{self._transport} timed out waiting for clock queue to drain, "
"pushing TTSStoppedFrame downstream anyway"
)
self._clock_flush_event = None self._clock_flush_event = None
self._clock_drained_event = None self._clock_drained_event = None