frame_processor: reset input queue flag with interruptions

This commit is contained in:
Aleix Conchillo Flaqué
2024-12-20 09:33:20 -08:00
parent 4547609ffb
commit 43759295cc
2 changed files with 4 additions and 0 deletions

View File

@@ -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.

View File

@@ -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()