From 22b3a24548e75ba8d6a85d8262471934a5b99b41 Mon Sep 17 00:00:00 2001 From: filipi87 Date: Fri, 27 Mar 2026 18:21:55 -0300 Subject: [PATCH] Fixing ruff format. --- src/pipecat/transports/base_output.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/pipecat/transports/base_output.py b/src/pipecat/transports/base_output.py index dba2f4412..73a97b5eb 100644 --- a/src/pipecat/transports/base_output.py +++ b/src/pipecat/transports/base_output.py @@ -835,7 +835,9 @@ class BaseOutputTransport(FrameProcessor): logger.debug(f"{self._transport} audio queue signalling clock queue flush") self._clock_flush_event.set() 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: logger.warning( 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 # push for this frame, so skip it here. 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() else: # Push frame downstream.