From ec5998bc36a4991d4964cfee106376f6e9af8fd5 Mon Sep 17 00:00:00 2001 From: joachimchauvet Date: Tue, 24 Sep 2024 14:54:37 +0300 Subject: [PATCH] remove _internal_push_frame from LiveKitInputTransport --- src/pipecat/transports/services/livekit.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/pipecat/transports/services/livekit.py b/src/pipecat/transports/services/livekit.py index 1dcb069ee..d6f00c3ef 100644 --- a/src/pipecat/transports/services/livekit.py +++ b/src/pipecat/transports/services/livekit.py @@ -326,7 +326,7 @@ class LiveKitInputTransport(BaseInputTransport): async def push_app_message(self, message: Any, sender: str): frame = LiveKitTransportMessageFrame(message=message, participant_id=sender) - await self._internal_push_frame(frame) + await self.push_frame(frame) async def _audio_in_task_handler(self): logger.info("Audio input task started") @@ -337,7 +337,7 @@ class LiveKitInputTransport(BaseInputTransport): audio_frame_event, participant_id = audio_data pipecat_audio_frame = self._convert_livekit_audio_to_pipecat(audio_frame_event) await self.push_audio_frame(pipecat_audio_frame) - await self._internal_push_frame( + await self.push_frame( pipecat_audio_frame ) # TODO: ensure audio frames are pushed with the default BaseInputTransport.push_audio_frame() except asyncio.CancelledError: