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 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() 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): 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 :]