From 1170b30c1be059ca4828724a848c9e2c1de6c723 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Aleix=20Conchillo=20Flaqu=C3=A9?= Date: Thu, 13 Jun 2024 13:30:31 -0700 Subject: [PATCH] aggregator(user_response): also handle small VADParams.stop_secs --- src/pipecat/processors/aggregators/user_response.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/pipecat/processors/aggregators/user_response.py b/src/pipecat/processors/aggregators/user_response.py index af87e1b0f..d8ab1756c 100644 --- a/src/pipecat/processors/aggregators/user_response.py +++ b/src/pipecat/processors/aggregators/user_response.py @@ -74,6 +74,8 @@ class ResponseAggregator(FrameProcessor): # S I T E -> X # S I E T -> X # S I E I T -> X + # S E T -> X + # S E I T -> X # # The following case would not be supported: # @@ -99,7 +101,7 @@ class ResponseAggregator(FrameProcessor): # We might have received the end frame but we might still be # aggregating (i.e. we have seen interim results but not the final # text). - self._aggregating = self._seen_interim_results + self._aggregating = self._seen_interim_results or len(self._aggregation) == 0 # Send the aggregation if we are not aggregating anymore (i.e. no # more interim results received).