Merge pull request #2032 from pipecat-ai/aleix/aws-nova-sonic-function-calls

AWSNovaSonicLLMService: fix function calling

CHANGELOG.md

@@ -39,6 +39,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Fixed
 
+- Fixed function calling in `AWSNovaSonicLLMService`.
+
 - Fixed an issue that would cause multiple `PipelineTask.on_idle_timeout`
   events to be triggered repeatedly.
 

src/pipecat/services/aws_nova_sonic/aws.py

@@ -25,6 +25,7 @@ from pipecat.frames.frames import (
     CancelFrame,
     EndFrame,
     Frame,
+    FunctionCallFromLLM,
     InputAudioRawFrame,
     InterimTranscriptionFrame,
     LLMFullResponseEndFrame,
@@ -804,12 +805,16 @@ class AWSNovaSonicLLMService(LLMService):
         # Call tool function
         if self.has_function(function_name):
             if function_name in self._functions.keys() or None in self._functions.keys():
-                await self.call_function(
+                function_calls_llm = [
-                    context=self._context,
+                    FunctionCallFromLLM(
-                    tool_call_id=tool_call_id,
+                        context=self._context,
-                    function_name=function_name,
+                        tool_call_id=tool_call_id,
-                    arguments=arguments,
+                        function_name=function_name,
-                )
+                        arguments=arguments,
+                    )
+                ]
+
+                await self.run_function_calls(function_calls_llm)
         else:
             raise AWSNovaSonicUnhandledFunctionException(
                 f"The LLM tried to call a function named '{function_name}', but there isn't a callback registered for that function."