diff --git a/src/pipecat/services/anthropic.py b/src/pipecat/services/anthropic.py index d74820b02..80235199b 100644 --- a/src/pipecat/services/anthropic.py +++ b/src/pipecat/services/anthropic.py @@ -804,8 +804,7 @@ class AnthropicAssistantContextAggregator(LLMAssistantContextAggregator): await properties.on_context_updated() # Push context frame - frame = OpenAILLMContextFrame(self._context) - await self.push_frame(frame) + await self.push_context_frame() # Push timestamp frame with current time timestamp_frame = OpenAILLMContextAssistantTimestampFrame(timestamp=time_now_iso8601()) diff --git a/src/pipecat/services/google/google.py b/src/pipecat/services/google/google.py index de53f9972..de88050c0 100644 --- a/src/pipecat/services/google/google.py +++ b/src/pipecat/services/google/google.py @@ -633,8 +633,7 @@ class GoogleAssistantContextAggregator(OpenAIAssistantContextAggregator): await properties.on_context_updated() # Push context frame - frame = OpenAILLMContextFrame(self._context) - await self.push_frame(frame) + await self.push_context_frame() # Push timestamp frame with current time timestamp_frame = OpenAILLMContextAssistantTimestampFrame(timestamp=time_now_iso8601()) diff --git a/src/pipecat/services/grok.py b/src/pipecat/services/grok.py index 5d1a731ff..1d1eb40d7 100644 --- a/src/pipecat/services/grok.py +++ b/src/pipecat/services/grok.py @@ -98,8 +98,7 @@ class GrokAssistantContextAggregator(OpenAIAssistantContextAggregator): if properties and properties.on_context_updated is not None: await properties.on_context_updated() - frame = OpenAILLMContextFrame(self._context) - await self.push_frame(frame) + await self.push_context_frame() except Exception as e: logger.error(f"Error processing frame: {e}") diff --git a/src/pipecat/services/openai.py b/src/pipecat/services/openai.py index d3628f4cb..b0a66eba0 100644 --- a/src/pipecat/services/openai.py +++ b/src/pipecat/services/openai.py @@ -692,8 +692,7 @@ class OpenAIAssistantContextAggregator(LLMAssistantContextAggregator): await properties.on_context_updated() # Push context frame - frame = OpenAILLMContextFrame(self._context) - await self.push_frame(frame) + await self.push_context_frame() # Push timestamp frame with current time timestamp_frame = OpenAILLMContextAssistantTimestampFrame(timestamp=time_now_iso8601()) diff --git a/src/pipecat/services/openai_realtime_beta/context.py b/src/pipecat/services/openai_realtime_beta/context.py index d88ed3314..31639dc6b 100644 --- a/src/pipecat/services/openai_realtime_beta/context.py +++ b/src/pipecat/services/openai_realtime_beta/context.py @@ -234,8 +234,7 @@ class OpenAIRealtimeAssistantContextAggregator(OpenAIAssistantContextAggregator) if properties and properties.on_context_updated is not None: await properties.on_context_updated() - frame = OpenAILLMContextFrame(self._context) - await self.push_frame(frame) + await self.push_context_frame() except Exception as e: logger.error(f"Error processing frame: {e}")