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

services: mark function calls as completed even the result is None

Browse Source
This commit is contained in:
Aleix Conchillo Flaqué
2025-03-19 14:34:31 -07:00
parent b1d506c137
commit e0c3f6ad83
3 changed files with 25 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/pipecat/services/anthropic.py
View File

@@ -711,12 +711,13 @@ class AnthropicAssistantContextAggregator(LLMAssistantContextAggregator):
) )
async def handle_function_call_result(self, frame: FunctionCallResultFrame): async def handle_function_call_result(self, frame: FunctionCallResultFrame):
if not frame.result: if frame.result:
return result = json.dumps(frame.result)
await self._update_function_call_result(frame.function_name, frame.tool_call_id, result)
result = json.dumps(frame.result) else:
await self._update_function_call_result(
await self._update_function_call_result(frame.function_name, frame.tool_call_id, result) frame.function_name, frame.tool_call_id, "COMPLETED"
)
async def handle_function_call_cancel(self, frame: FunctionCallCancelFrame): async def handle_function_call_cancel(self, frame: FunctionCallCancelFrame):
await self._update_function_call_result( await self._update_function_call_result(

18
src/pipecat/services/google/google.py
View File

@@ -600,15 +600,19 @@ class GoogleAssistantContextAggregator(OpenAIAssistantContextAggregator):
) )
async def handle_function_call_result(self, frame: FunctionCallResultFrame): async def handle_function_call_result(self, frame: FunctionCallResultFrame):
if not frame.result: if frame.result:
return if not isinstance(frame.result, str):
return
if not isinstance(frame.result, str): response = {"response": frame.result}
return
response = {"response": frame.result} await self._update_function_call_result(
frame.function_name, frame.tool_call_id, response
await self._update_function_call_result(frame.function_name, frame.tool_call_id, response) )
else:
await self._update_function_call_result(
frame.function_name, frame.tool_call_id, "COMPLETED"
)
async def handle_function_call_cancel(self, frame: FunctionCallCancelFrame): async def handle_function_call_cancel(self, frame: FunctionCallCancelFrame):
await self._update_function_call_result( await self._update_function_call_result(

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

@@ -584,12 +584,13 @@ class OpenAIAssistantContextAggregator(LLMAssistantContextAggregator):
) )
async def handle_function_call_result(self, frame: FunctionCallResultFrame): async def handle_function_call_result(self, frame: FunctionCallResultFrame):
if not frame.result: if frame.result:
return result = json.dumps(frame.result)
await self._update_function_call_result(frame.function_name, frame.tool_call_id, result)
result = json.dumps(frame.result) else:
await self._update_function_call_result(
await self._update_function_call_result(frame.function_name, frame.tool_call_id, result) frame.function_name, frame.tool_call_id, "COMPLETED"
)
async def handle_function_call_cancel(self, frame: FunctionCallCancelFrame): async def handle_function_call_cancel(self, frame: FunctionCallCancelFrame):
await self._update_function_call_result( await self._update_function_call_result(