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

Fixing ruff format.

Browse Source
This commit is contained in:
filipi87
2026-03-27 18:21:55 -03:00
parent de1fd67b2d
commit 22b3a24548
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -835,7 +835,9 @@ class BaseOutputTransport(FrameProcessor):
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()
try: try:
await asyncio.wait_for(self._clock_drained_event.wait(), timeout=BOT_VAD_STOP_FALLBACK_SECS) await asyncio.wait_for(
self._clock_drained_event.wait(), timeout=BOT_VAD_STOP_FALLBACK_SECS
)
except asyncio.TimeoutError: except asyncio.TimeoutError:
logger.warning( logger.warning(
f"{self._transport} timed out waiting for clock queue to drain, " f"{self._transport} timed out waiting for clock queue to drain, "
@@ -1029,7 +1031,9 @@ class BaseOutputTransport(FrameProcessor):
# the drain is complete. The audio task owns the downstream # the drain is complete. The audio task owns the downstream
# push for this frame, so skip it here. # push for this frame, so skip it here.
if isinstance(frame, TTSStoppedFrame) and self._clock_drained_event is not None: if isinstance(frame, TTSStoppedFrame) and self._clock_drained_event is not None:
logger.debug(f"{self._transport} clock queue drained, handing off TTSStoppedFrame to audio queue") logger.debug(
f"{self._transport} clock queue drained, handing off TTSStoppedFrame to audio queue"
)
self._clock_drained_event.set() self._clock_drained_event.set()
else: else:
# Push frame downstream. # Push frame downstream.