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

Transports now send InputTransportMessageFrames (not Urgent Frames)

Browse Source
This commit is contained in:
mattie ruth backman
2025-10-03 09:32:47 -04:00
committed by Mattie Ruth
parent 4abe4a6253
commit 8d38994756
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
CHANGELOG.md
View File

@@ -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. - 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 ## [0.0.87] - 2025-10-02
### Added ### Added

6
src/pipecat/processors/frameworks/rtvi.py
View File

@@ -42,7 +42,7 @@ from pipecat.frames.frames import (
Frame, Frame,
FunctionCallResultFrame, FunctionCallResultFrame,
InputAudioRawFrame, InputAudioRawFrame,
InputTransportMessageUrgentFrame, InputTransportMessageFrame,
InterimTranscriptionFrame, InterimTranscriptionFrame,
LLMConfigureOutputFrame, LLMConfigureOutputFrame,
LLMContextFrame, LLMContextFrame,
@@ -1421,7 +1421,7 @@ class RTVIProcessor(FrameProcessor):
elif isinstance(frame, ErrorFrame): elif isinstance(frame, ErrorFrame):
await self._send_error_frame(frame) await self._send_error_frame(frame)
await self.push_frame(frame, direction) await self.push_frame(frame, direction)
elif isinstance(frame, InputTransportMessageUrgentFrame): elif isinstance(frame, InputTransportMessageFrame):
await self._handle_transport_message(frame) await self._handle_transport_message(frame)
# All other system frames # All other system frames
elif isinstance(frame, SystemFrame): elif isinstance(frame, SystemFrame):
@@ -1484,7 +1484,7 @@ class RTVIProcessor(FrameProcessor):
await self._handle_message(message) await self._handle_message(message)
self._message_queue.task_done() 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.""" """Handle an incoming transport message frame."""
try: try:
transport_message = frame.message transport_message = frame.message