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

Clean up TTFB metrics and previous_response state on retry failure

Browse Source
This commit is contained in:
Paul Kompfner
2026-03-30 23:00:22 -04:00
parent 9ad4fe6344
commit f19d1183d8
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/pipecat/services/openai/responses/llm.py
View File

@@ -789,10 +789,15 @@ class OpenAIResponsesLLMService(_BaseOpenAIResponsesLLMService, WebsocketLLMServ
params = self._build_response_params(invocation_params) params = self._build_response_params(invocation_params)
params.pop("stream", None) params.pop("stream", None)
await self._ensure_connected() try:
await self.start_ttfb_metrics() await self._ensure_connected()
await self._ws_send({"type": "response.create", **params}) await self.start_ttfb_metrics()
await self._receive_response_events(context, full_input) await self._ws_send({"type": "response.create", **params})
await self._receive_response_events(context, full_input)
except Exception:
self._clear_previous_response_state()
await self.stop_ttfb_metrics()
raise
async def _receive_response_events(self, context: LLMContext, full_input: list): async def _receive_response_events(self, context: LLMContext, full_input: list):
"""Receive and process WebSocket events until the response completes. """Receive and process WebSocket events until the response completes.