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

Comment tweak

Browse Source
This commit is contained in:
Paul Kompfner
2025-03-20 12:41:40 -04:00
parent ada68f0699
commit 721ee75887
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -136,10 +136,11 @@ class OpenAIRealtimeBetaLLMService(LLMService):
self._retrieve_conversation_item_futures[item_id].append(future) self._retrieve_conversation_item_futures[item_id].append(future)
if not retrieval_in_flight: if not retrieval_in_flight:
await self.send_client_event( await self.send_client_event(
# Set event_id to "rci_{item_id}" so that we can identiy an # Set event_id to "rci_{item_id}" so that we can identify an
# error later if the retrieval fails. We don't need a UUID # error later if the retrieval fails. We don't need a UUID
# suffix to the event_id because we're ensuring only one # suffix to the event_id because we're ensuring only one
# in-flight retrieval per item_id # in-flight retrieval per item_id. (Note: "rci" = "retrieve
# conversation item")
events.ConversationItemRetrieveEvent(item_id=item_id, event_id=f"rci_{item_id}") events.ConversationItemRetrieveEvent(item_id=item_id, event_id=f"rci_{item_id}")
) )
return await future return await future