From e1169a4e82d18fb7f369943d6e2ff35dc49ee05d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Wed, 22 May 2024 15:43:52 -0700 Subject: [PATCH] processors(WakeCheckFilter): push error --- src/pipecat/processors/filters/wake_check_filter.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/src/pipecat/processors/filters/wake_check_filter.py b/src/pipecat/processors/filters/wake_check_filter.py index 459ee5f75..4f976fc72 100644 --- a/src/pipecat/processors/filters/wake_check_filter.py +++ b/src/pipecat/processors/filters/wake_check_filter.py @@ -9,7 +9,7 @@ import time from enum import Enum -from pipecat.frames.frames import Frame, TranscriptionFrame +from pipecat.frames.frames import ErrorFrame, Frame, TranscriptionFrame from pipecat.processors.frame_processor import FrameDirection, FrameProcessor from loguru import logger @@ -79,4 +79,6 @@ class WakeCheckFilter(FrameProcessor): else: await self.push_frame(frame, direction) except Exception as e: - logger.error(f"Error in wake word filter: {e}") + error_msg = f"Error in wake word filter: {e}" + logger.error(error_msg) + await self.push_error(ErrorFrame(error_msg))