From a80dc94e9131b23e9125b82978f3e9a62a49e899 Mon Sep 17 00:00:00 2001 From: Filipi Fuchter Date: Thu, 17 Apr 2025 16:47:17 -0300 Subject: [PATCH] Fixing ruff format. --- src/pipecat/transports/base_input.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/pipecat/transports/base_input.py b/src/pipecat/transports/base_input.py index b43b71a49..5ff7723ec 100644 --- a/src/pipecat/transports/base_input.py +++ b/src/pipecat/transports/base_input.py @@ -221,12 +221,12 @@ class BaseInputTransport(FrameProcessor): await self.push_frame(UserEndOfTurnFrame()) await self._handle_user_interruption(UserStoppedSpeakingFrame()) - async def _run_turn_analyzer(self, frame: InputAudioRawFrame, vad_state: VADState, previous_vad_state: VADState): + async def _run_turn_analyzer( + self, frame: InputAudioRawFrame, vad_state: VADState, previous_vad_state: VADState + ): is_speech = vad_state == VADState.SPEAKING or vad_state == VADState.STARTING # If silence exceeds threshold, we are going to receive EndOfTurnState.COMPLETE - end_of_turn_state = self._params.end_of_turn_analyzer.append_audio( - frame.audio, is_speech - ) + end_of_turn_state = self._params.end_of_turn_analyzer.append_audio(frame.audio, is_speech) if end_of_turn_state == EndOfTurnState.COMPLETE: await self._handle_end_of_turn_complete(end_of_turn_state) # Otherwise we are going to trigger to check if the turn is completed based on the VAD