diff --git a/src/pipecat/services/riva/stt.py b/src/pipecat/services/riva/stt.py index f077355f4..ccd166536 100644 --- a/src/pipecat/services/riva/stt.py +++ b/src/pipecat/services/riva/stt.py @@ -583,7 +583,7 @@ class RivaSegmentedSTTService(SegmentedSTTService): self._config.language_code = self._language @traced_stt - async def _handle_transcription(self, transcript: str, language: Optional[Language] = None): + async def _handle_transcription(self, transcript: str, is_final: bool, language: Optional[Language] = None): """Handle a transcription result with tracing.""" pass @@ -647,7 +647,7 @@ class RivaSegmentedSTTService(SegmentedSTTService): ) transcription_found = True - await self._handle_transcription(text, self._language_enum) + await self._handle_transcription(text, True, self._language_enum) if not transcription_found: logger.debug("No transcription results found in Riva response")