Merge pull request #898 from pipecat-ai/aleix/reset-input-queue-flag-if-interruption

frame_processor: reset input queue flag with interruptions

CHANGELOG.md

@@ -72,6 +72,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.
 

src/pipecat/processors/frame_processor.py

@@ -268,6 +268,7 @@ class FrameProcessor:
             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()