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

Merge pull request #3614 from okue/fix/websocket-broadcast-frame-misuse

Browse Source 
fix: pass frame class instead of instance to broadcast_frame in websocket transports
This commit is contained in:
Mark Backman
2026-02-05 12:19:03 -05:00
committed by GitHub
parent 8f42343927 d3ecbb11c1
commit bd12b60b5c
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/pipecat/transports/websocket/client.py
View File

@@ -300,7 +300,7 @@ class WebsocketClientInputTransport(BaseInputTransport):
if isinstance(frame, InputAudioRawFrame) and self._params.audio_in_enabled: if isinstance(frame, InputAudioRawFrame) and self._params.audio_in_enabled:
await self.push_audio_frame(frame) await self.push_audio_frame(frame)
elif isinstance(frame, InputTransportMessageFrame): elif isinstance(frame, InputTransportMessageFrame):
await self.broadcast_frame(frame) await self.broadcast_frame(InputTransportMessageFrame, message=frame.message)
else: else:
await self.push_frame(frame) await self.push_frame(frame)

2
src/pipecat/transports/websocket/fastapi.py
View File

@@ -313,7 +313,7 @@ class FastAPIWebsocketInputTransport(BaseInputTransport):
if isinstance(frame, InputAudioRawFrame): if isinstance(frame, InputAudioRawFrame):
await self.push_audio_frame(frame) await self.push_audio_frame(frame)
elif isinstance(frame, InputTransportMessageFrame): elif isinstance(frame, InputTransportMessageFrame):
await self.broadcast_frame(frame) await self.broadcast_frame(InputTransportMessageFrame, message=frame.message)
else: else:
await self.push_frame(frame) await self.push_frame(frame)
except Exception as e: except Exception as e:

2
src/pipecat/transports/websocket/server.py
View File

@@ -217,7 +217,7 @@ class WebsocketServerInputTransport(BaseInputTransport):
if isinstance(frame, InputAudioRawFrame): if isinstance(frame, InputAudioRawFrame):
await self.push_audio_frame(frame) await self.push_audio_frame(frame)
elif isinstance(frame, InputTransportMessageFrame): elif isinstance(frame, InputTransportMessageFrame):
await self.broadcast_frame(frame) await self.broadcast_frame(InputTransportMessageFrame, message=frame.message)
else: else:
await self.push_frame(frame) await self.push_frame(frame)
except Exception as e: except Exception as e: