diff --git a/src/pipecat/processors/frameworks/rtvi.py b/src/pipecat/processors/frameworks/rtvi.py index 909dd15b7..c2f7004ba 100644 --- a/src/pipecat/processors/frameworks/rtvi.py +++ b/src/pipecat/processors/frameworks/rtvi.py @@ -639,8 +639,6 @@ class RTVIProcessor(FrameProcessor): super().__init__(**kwargs) self._config = config - self._pipeline: Optional[FrameProcessor] = None - self._bot_ready = False self._client_ready = False self._client_ready_id = "" @@ -754,11 +752,6 @@ class RTVIProcessor(FrameProcessor): else: await self.push_frame(frame, direction) - async def cleanup(self): - await super().cleanup() - if self._pipeline: - await self._pipeline.cleanup() - async def _start(self, frame: StartFrame): if not self._action_task: self._action_task = self.create_task(self._action_task_handler())