diff --git a/CHANGELOG.md b/CHANGELOG.md index 87187becc..0a0d3aa5d 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -15,6 +15,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 - Added `hume` optional dependency group for Hume AI TTS integration. +### Fixed + +- Fixed RTVI incoming message handling, broken in 0.0.87. + ## [0.0.87] - 2025-10-02 ### Added diff --git a/src/pipecat/processors/frameworks/rtvi.py b/src/pipecat/processors/frameworks/rtvi.py index 4d1f8aeae..393cb7115 100644 --- a/src/pipecat/processors/frameworks/rtvi.py +++ b/src/pipecat/processors/frameworks/rtvi.py @@ -42,7 +42,7 @@ from pipecat.frames.frames import ( Frame, FunctionCallResultFrame, InputAudioRawFrame, - InputTransportMessageUrgentFrame, + InputTransportMessageFrame, InterimTranscriptionFrame, LLMConfigureOutputFrame, LLMContextFrame, @@ -1421,7 +1421,7 @@ class RTVIProcessor(FrameProcessor): elif isinstance(frame, ErrorFrame): await self._send_error_frame(frame) await self.push_frame(frame, direction) - elif isinstance(frame, InputTransportMessageUrgentFrame): + elif isinstance(frame, InputTransportMessageFrame): await self._handle_transport_message(frame) # All other system frames elif isinstance(frame, SystemFrame): @@ -1484,7 +1484,7 @@ class RTVIProcessor(FrameProcessor): await self._handle_message(message) self._message_queue.task_done() - async def _handle_transport_message(self, frame: InputTransportMessageUrgentFrame): + async def _handle_transport_message(self, frame: InputTransportMessageFrame): """Handle an incoming transport message frame.""" try: transport_message = frame.message