wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add response.done status=failed error

Browse Source
This commit is contained in:
Kwindla Hultman Kramer
2025-03-16 18:40:19 -07:00
committed by Paul Kompfner
parent bfdf52bd69
commit 4449e9a25b
2 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
examples/foundational/19-openai-realtime-beta.py
View File

@@ -114,7 +114,6 @@ Remember, your responses should be short. Just one or two sentences, usually."""
llm = OpenAIRealtimeBetaLLMService( llm = OpenAIRealtimeBetaLLMService(
api_key=os.getenv("OPENAI_API_KEY"), api_key=os.getenv("OPENAI_API_KEY"),
model="gpt-4o-realtime-preview-latest",
session_properties=session_properties, session_properties=session_properties,
start_audio_paused=False, start_audio_paused=False,
) )

7
src/pipecat/services/openai_realtime_beta/openai.py
View File

@@ -87,7 +87,8 @@ class OpenAIRealtimeBetaLLMService(LLMService):
self, self,
*, *,
api_key: str, api_key: str,
model: str = "gpt-4o-realtime-preview-2024-12-17", # model: str = "gpt-4o-realtime-preview-2024-12-17",
model: str = "gpt-4o-realtime-preview-latest",
base_url: str = "wss://api.openai.com/v1/realtime", base_url: str = "wss://api.openai.com/v1/realtime",
session_properties: events.SessionProperties = events.SessionProperties(), session_properties: events.SessionProperties = events.SessionProperties(),
start_audio_paused: bool = False, start_audio_paused: bool = False,
@@ -465,6 +466,10 @@ class OpenAIRealtimeBetaLLMService(LLMService):
await self.stop_processing_metrics() await self.stop_processing_metrics()
await self.push_frame(LLMFullResponseEndFrame()) await self.push_frame(LLMFullResponseEndFrame())
self._current_assistant_response = None self._current_assistant_response = None
# error handling
if evt.response.status == "failed":
await self.push_error(ErrorFrame(error=evt.response.status_details["error"]["message"], fatal=True))
return
# response content # response content
pair = self._user_and_response_message_tuple pair = self._user_and_response_message_tuple
if pair: if pair: