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

Merge pull request #3795 from omChauhanDev/fix/realtime-cancel-not-active

Browse Source 
fix(realtime): handle response_cancel_not_active as non-fatal
This commit is contained in:
Mark Backman
2026-03-01 07:29:59 -05:00
committed by GitHub
parent 17205c1647 ece4343839
commit dee94b3cb8
4 changed files with 18 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
changelog/3795.fixed.md Normal file
View File

@@ -0,0 +1 @@
- Treated `response_cancel_not_active` as a non-fatal error in realtime services (`OpenAIRealtimeLLMService`, `GrokRealtimeLLMService`, `OpenAIRealtimeBetaLLMService`) to prevent WebSocket disconnection when cancelling an inactive response.

7
src/pipecat/services/grok/realtime/llm.py
View File

@@ -571,8 +571,11 @@ class GrokRealtimeLLMService(LLMService):
elif evt.type == "response.function_call_arguments.done": elif evt.type == "response.function_call_arguments.done":
await self._handle_evt_function_call_arguments_done(evt) await self._handle_evt_function_call_arguments_done(evt)
elif evt.type == "error": elif evt.type == "error":
await self._handle_evt_error(evt) if evt.error.code == "response_cancel_not_active":
return logger.debug(f"{self} {evt.error.message}")
else:
await self._handle_evt_error(evt)
return
async def _handle_evt_conversation_created(self, evt): async def _handle_evt_conversation_created(self, evt):
"""Handle conversation.created event - first event after connecting.""" """Handle conversation.created event - first event after connecting."""

9
src/pipecat/services/openai/realtime/llm.py
View File

@@ -618,9 +618,12 @@ class OpenAIRealtimeLLMService(LLMService):
await self._handle_evt_function_call_arguments_done(evt) await self._handle_evt_function_call_arguments_done(evt)
elif evt.type == "error": elif evt.type == "error":
if not await self._maybe_handle_evt_retrieve_conversation_item_error(evt): if not await self._maybe_handle_evt_retrieve_conversation_item_error(evt):
await self._handle_evt_error(evt) if evt.error.code == "response_cancel_not_active":
# errors are fatal, so exit the receive loop logger.debug(f"{self} {evt.error.message}")
return else:
await self._handle_evt_error(evt)
# errors are fatal, so exit the receive loop
return
@traced_openai_realtime(operation="llm_setup") @traced_openai_realtime(operation="llm_setup")
async def _handle_evt_session_created(self, evt): async def _handle_evt_session_created(self, evt):

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

@@ -544,9 +544,12 @@ class OpenAIRealtimeBetaLLMService(LLMService):
await self._handle_evt_audio_transcript_delta(evt) await self._handle_evt_audio_transcript_delta(evt)
elif evt.type == "error": elif evt.type == "error":
if not await self._maybe_handle_evt_retrieve_conversation_item_error(evt): if not await self._maybe_handle_evt_retrieve_conversation_item_error(evt):
await self._handle_evt_error(evt) if evt.error.code == "response_cancel_not_active":
# errors are fatal, so exit the receive loop logger.debug(f"{self} {evt.error.message}")
return else:
await self._handle_evt_error(evt)
# errors are fatal, so exit the receive loop
return
@traced_openai_realtime(operation="llm_setup") @traced_openai_realtime(operation="llm_setup")
async def _handle_evt_session_created(self, evt): async def _handle_evt_session_created(self, evt):