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

Adding some comments to the code.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-04-16 09:11:27 -03:00
parent cd8bd7f487
commit 8e36bdbed7
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_input.py
View File

@@ -244,11 +244,13 @@ class BaseInputTransport(FrameProcessor):
if self._params.end_of_turn_analyzer: if self._params.end_of_turn_analyzer:
is_speech = vad_state == VADState.SPEAKING or vad_state == VADState.STARTING 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( end_of_turn_state = self._params.end_of_turn_analyzer.append_audio(
frame.audio, is_speech frame.audio, is_speech
) )
if end_of_turn_state == EndOfTurnState.COMPLETE: if end_of_turn_state == EndOfTurnState.COMPLETE:
await self._handle_end_of_turn_complete(end_of_turn_state) 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
elif vad_state == VADState.QUIET and vad_state != previous_vad_state: elif vad_state == VADState.QUIET and vad_state != previous_vad_state:
await self._handle_end_of_turn() await self._handle_end_of_turn()