From fc24267e0973a785d7b45d064038815d44b2bf5b Mon Sep 17 00:00:00 2001 From: Filipi Fuchter Date: Mon, 2 Jun 2025 22:15:53 -0300 Subject: [PATCH 1/4] Waiting for the LLM response to reset. --- src/pipecat/services/google/llm.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/pipecat/services/google/llm.py b/src/pipecat/services/google/llm.py index b63b3786c..8960bda31 100644 --- a/src/pipecat/services/google/llm.py +++ b/src/pipecat/services/google/llm.py @@ -83,7 +83,7 @@ class GoogleUserContextAggregator(OpenAIUserContextAggregator): await self.push_frame(frame) # Reset our accumulator state. - self.reset() + await self.reset() class GoogleAssistantContextAggregator(OpenAIAssistantContextAggregator): From 892d213442060d31b9784fbb111717209b575a96 Mon Sep 17 00:00:00 2001 From: Filipi Fuchter Date: Mon, 2 Jun 2025 22:16:10 -0300 Subject: [PATCH 2/4] Fixing issue to keep the transport_destination. --- src/pipecat/transports/base_output.py | 1 + 1 file changed, 1 insertion(+) diff --git a/src/pipecat/transports/base_output.py b/src/pipecat/transports/base_output.py index dabd92829..386f223d7 100644 --- a/src/pipecat/transports/base_output.py +++ b/src/pipecat/transports/base_output.py @@ -351,6 +351,7 @@ class BaseOutputTransport(FrameProcessor): sample_rate=self._sample_rate, num_channels=frame.num_channels, ) + chunk.transport_destination = self._destination await self._audio_queue.put(chunk) self._audio_buffer = self._audio_buffer[self._audio_chunk_size :] From 1642c082d1e529519f4d30da9d2d6b59c26e4b1a Mon Sep 17 00:00:00 2001 From: Filipi Fuchter Date: Mon, 2 Jun 2025 22:28:31 -0300 Subject: [PATCH 3/4] Describing the fix in the changelog. --- CHANGELOG.md | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/CHANGELOG.md b/CHANGELOG.md index adb654c06..bf47be81a 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -5,6 +5,15 @@ All notable changes to **Pipecat** will be documented in this file. The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/), and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html). + +## [Unreleased] + +### Fixed + +- Fixed an issue where `OutputAudioRawFrame.transport_destination` was being + reset to `None` instead of retaining its intended value before sending the + audio frame to `write_audio_frame`. + ## [0.0.69] - 2025-06-02 "AI Engineer World's Fair release" ✨ ### Added From 31ca9be2998f7d3e93e8599dc6dec697c9b5ccb9 Mon Sep 17 00:00:00 2001 From: Filipi Fuchter Date: Tue, 3 Jun 2025 08:37:47 -0300 Subject: [PATCH 4/4] Fixing missing await to self.reset. --- src/pipecat/processors/aggregators/user_response.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/pipecat/processors/aggregators/user_response.py b/src/pipecat/processors/aggregators/user_response.py index 6998fe200..8831f7d10 100644 --- a/src/pipecat/processors/aggregators/user_response.py +++ b/src/pipecat/processors/aggregators/user_response.py @@ -23,4 +23,4 @@ class UserResponseAggregator(LLMUserResponseAggregator): await self.push_frame(frame) # Reset our accumulator state. - self.reset() + await self.reset()