diff --git a/src/pipecat/transports/smallwebrtc/transport.py b/src/pipecat/transports/smallwebrtc/transport.py index 0e2ea544e4..e8e0a4ae94 100644 --- a/src/pipecat/transports/smallwebrtc/transport.py +++ b/src/pipecat/transports/smallwebrtc/transport.py @@ -332,6 +332,7 @@ async def read_video_frame(self, video_source: str): format="RGB", ) image_frame.transport_source = video_source + image_frame.pts = frame.pts del frame # free original VideoFrame del image_bytes # reference kept in image_frame @@ -379,6 +380,7 @@ async def read_audio_frame(self): sample_rate=resampled_frame.sample_rate, num_channels=self._audio_in_channels, ) + audio_frame.pts = frame.pts del pcm_bytes # reference kept in audio_frame yield audio_frame @@ -393,6 +395,7 @@ async def read_audio_frame(self): sample_rate=frame.sample_rate, num_channels=self._audio_in_channels, ) + audio_frame.pts = frame.pts del pcm_bytes # reference kept in audio_frame yield audio_frame