BaseInputTransport: stop audio filter on cancel

2025-10-15 09:22:48 -07:00
parent 8fe3bcd484
commit 83b0dc39f7
2 changed files with 6 additions and 0 deletions
--- a/src/pipecat/transports/base_input.py
+++ b/src/pipecat/transports/base_input.py
@@ -232,6 +232,9 @@ class BaseInputTransport(FrameProcessor):
        """
        # Cancel and wait for the audio input task to finish.
        await self._cancel_audio_task()
+        # Stop audio filter.
+        if self._params.audio_in_filter:
+            await self._params.audio_in_filter.stop()

    async def set_transport_ready(self, frame: StartFrame):
        """Called when the transport is ready to stream.