From 43759295cc9f10721dbb659a27068d51e82a55ea Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Fri, 20 Dec 2024 09:33:20 -0800 Subject: [PATCH] frame_processor: reset input queue flag with interruptions --- CHANGELOG.md | 3 +++ src/pipecat/processors/frame_processor.py | 1 + 2 files changed, 4 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index 526775b16..93877bb5d 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -66,6 +66,9 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0 ### Fixed +- Fixed an issue that could cause the bot to stop talking if there was a user + interruption before getting any audio from the TTS service. + - Fixed an issue that would cause `ParallelPipeline` to handle `EndFrame` incorrectly causing the main pipeline to not terminate or terminate too early. diff --git a/src/pipecat/processors/frame_processor.py b/src/pipecat/processors/frame_processor.py index 52066b4f4..e3dfe0bce 100644 --- a/src/pipecat/processors/frame_processor.py +++ b/src/pipecat/processors/frame_processor.py @@ -268,6 +268,7 @@ async def __internal_push_frame(self, frame: Frame, direction: FrameDirection): raise def __create_input_task(self): + self.__should_block_frames = False self.__input_queue = asyncio.Queue() self.__input_frame_task = self.get_event_loop().create_task( self.__input_frame_task_handler()