transport(base): clear audio output buffer if interrupted

pipecat-ai · May 22, 2024 · 3438488 · 3438488
1 parent 71ba287
commit 3438488
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 27 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -19,6 +19,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Fixed
 
+- Clear the audio output buffer if we are interrupted.
+
 - Re-add exponential smoothing after volume calculation. This makes sure the
   volume value being used doesn't fluctuate so much.
 

diff --git a/src/pipecat/processors/utils/audio.py b/src/pipecat/processors/utils/audio.py
diff --git a/src/pipecat/transports/base_output.py b/src/pipecat/transports/base_output.py
@@ -175,8 +175,7 @@ def _sink_thread_handler(self):
                             self._internal_push_frame(frame), self.get_event_loop())
                         future.result()
                 else:
-                    # Send any remaining audio
-                    self._send_audio_truncated(buffer, bytes_size_10ms)
+                    # If we get interrupted just clear the output buffer.
                     buffer = bytearray()
 
                 if isinstance(frame, EndFrame):