Update

Author: dirkbrnd

libs/agno/agno/knowledge/agent.py

@@ -123,7 +123,8 @@ def load(
 
             # Upsert documents if upsert is True and vector db supports upsert
             if upsert and self.vector_db.upsert_available():
-                self.vector_db.upsert(documents=document_list, filters=doc.meta_data)
+                for doc in document_list:
+                    self.vector_db.upsert(documents=[doc], filters=doc.meta_data)
             # Insert documents
             else:
                 # Filter out documents which already exist in the vector db
@@ -132,7 +133,8 @@ def load(
                     documents_to_load = self.filter_existing_documents(document_list)
 
                 if documents_to_load:
-                    self.vector_db.insert(documents=documents_to_load, filters=doc.meta_data)
+                    for doc in documents_to_load:
+                        self.vector_db.insert(documents=[doc], filters=doc.meta_data)
 
             num_documents += len(documents_to_load)
             log_info(f"Added {len(documents_to_load)} documents to knowledge base")
@@ -174,7 +176,8 @@ async def aload(
 
             # Upsert documents if upsert is True and vector db supports upsert
             if upsert and self.vector_db.upsert_available():
-                await self.vector_db.async_upsert(documents=document_list, filters=doc.meta_data)
+                for doc in document_list:
+                    await self.vector_db.async_upsert(documents=[doc], filters=doc.meta_data)
             # Insert documents
             else:
                 # Filter out documents which already exist in the vector db
@@ -183,7 +186,8 @@ async def aload(
                     documents_to_load = self.filter_existing_documents(document_list)
 
                 if documents_to_load:
-                    await self.vector_db.async_insert(documents=documents_to_load, filters=doc.meta_data)
+                    for doc in documents_to_load:
+                        await self.vector_db.async_insert(documents=[doc], filters=doc.meta_data)
 
             num_documents += len(documents_to_load)
             log_info(f"Added {len(documents_to_load)} documents to knowledge base")

libs/agno/agno/models/base.py

@@ -104,8 +104,12 @@ def _add_usage_metrics_to_assistant_message(assistant_message: Message, response
             )
 
     # If you didn't capture any total tokens
-    if (assistant_message.metrics.input_tokens or assistant_message.metrics.output_tokens) and not assistant_message.metrics.total_tokens:
-        assistant_message.metrics.total_tokens = assistant_message.metrics.input_tokens + assistant_message.metrics.output_tokens
+    if (
+        assistant_message.metrics.input_tokens or assistant_message.metrics.output_tokens
+    ) and not assistant_message.metrics.total_tokens:
+        assistant_message.metrics.total_tokens = (
+            assistant_message.metrics.input_tokens + assistant_message.metrics.output_tokens
+        )
 
     # Additional metrics (e.g., from Groq, Ollama)
     if isinstance(response_usage, dict) and "additional_metrics" in response_usage:

libs/agno/agno/tools/apify.py

@@ -156,7 +156,7 @@ def actor_function(**kwargs) -> str:
             actor_function.__doc__ = docstring
 
             # Register the function with the toolkit
-            self.register(actor_function, sanitize_arguments=False)
+            self.register(actor_function)
             # Fix params schema
             self.functions[tool_name].parameters = props_to_json_schema(properties, required)
             log_info(f"Registered Apify Actor '{actor_id}' as function '{tool_name}'")

libs/agno/agno/tools/decorator.py

@@ -48,7 +48,7 @@ def tool(*args, **kwargs) -> Union[Function, Callable[[F], Function]]:
         name: Optional[str] - Override for the function name
         description: Optional[str] - Override for the function description
         strict: Optional[bool] - Flag for strict parameter checking
-        sanitize_arguments: Optional[bool] - If True, arguments are sanitized before passing to function
+        sanitize_arguments: Optional[bool] - If True, arguments are sanitized before passing to function (Deprecated)
         instructions: Optional[str] - Instructions for using the tool
         add_instructions: bool - If True, add instructions to the system message
         show_result: Optional[bool] - If True, shows the result after function call

libs/agno/agno/tools/function.py

@@ -83,8 +83,8 @@ class Function(BaseModel):
     entrypoint: Optional[Callable] = None
     # If True, the entrypoint processing is skipped and the Function is used as is.
     skip_entrypoint_processing: bool = False
-    # If True, the arguments are sanitized before being passed to the function.
-    sanitize_arguments: bool = True
+    # If True, the arguments are sanitized before being passed to the function. (Deprecated)
+    sanitize_arguments: bool = False
     # If True, the function call will show the result along with sending it to the model.
     show_result: bool = False
     # If True, the agent will stop after the function call.

libs/agno/agno/tools/toolkit.py

@@ -105,12 +105,11 @@ def _register_tools(self) -> None:
         for tool in self.tools:
             self.register(tool)
 
-    def register(self, function: Callable[..., Any], sanitize_arguments: bool = True, name: Optional[str] = None):
+    def register(self, function: Callable[..., Any], name: Optional[str] = None):
         """Register a function with the toolkit.
 
         Args:
             function: The callable to register
-            sanitize_arguments: Whether to sanitize arguments before passing to the function
             name: Optional custom name for the function
 
         Returns:
@@ -126,7 +125,6 @@ def register(self, function: Callable[..., Any], sanitize_arguments: bool = True
             f = Function(
                 name=tool_name,
                 entrypoint=function,
-                sanitize_arguments=sanitize_arguments,
                 cache_results=self.cache_results,
                 cache_dir=self.cache_dir,
                 cache_ttl=self.cache_ttl,

libs/agno/agno/utils/functions.py

@@ -28,14 +28,12 @@ def get_function_call(
         function_call.call_id = call_id
     if arguments is not None and arguments != "":
         try:
-            if function_to_call.sanitize_arguments:
-                if "None" in arguments:
-                    arguments = arguments.replace("None", "null")
-                if "True" in arguments:
-                    arguments = arguments.replace("True", "true")
-                if "False" in arguments:
-                    arguments = arguments.replace("False", "false")
-            _arguments = json.loads(arguments)
+            try:
+                _arguments = json.loads(arguments)
+            except Exception:
+                import ast
+
+                _arguments = ast.literal_eval(arguments)
         except Exception as e:
             log_error(f"Unable to decode function arguments:\n{arguments}\nError: {e}")
             function_call.error = (

libs/agno/agno/utils/models/aws_claude.py

@@ -151,7 +151,7 @@ def format_messages(messages: List[Message]) -> Tuple[List[Dict[str, str]], str]
         elif message.role == "assistant":
             content = []
 
-            if isinstance(message.content, str) and message.content:
+            if isinstance(message.content, str) and message.content and len(message.content.strip()) > 0:
                 content.append(TextBlock(text=message.content, type="text"))
 
             if message.tool_calls:

libs/agno/agno/utils/models/claude.py

@@ -245,7 +245,7 @@ def format_messages(messages: List[Message]) -> Tuple[List[Dict[str, str]], str]
 
                 content.append(RedactedThinkingBlock(data=message.redacted_thinking, type="redacted_thinking"))
 
-            if isinstance(message.content, str) and message.content:
+            if isinstance(message.content, str) and message.content and len(message.content.strip()) > 0:
                 content.append(TextBlock(text=message.content, type="text"))
 
             if message.tool_calls:

libs/agno/tests/unit/tools/test_functions.py

@@ -533,7 +533,6 @@ def test_tool_decorator_with_config():
         strict=True,
         instructions="Custom instructions",
         add_instructions=False,
-        sanitize_arguments=False,
         show_result=True,
         stop_after_tool_call=True,
         requires_confirmation=True,
@@ -551,7 +550,6 @@ def configured_func() -> str:
     assert configured_func.strict is True
     assert configured_func.instructions == "Custom instructions"
     assert configured_func.add_instructions is False
-    assert configured_func.sanitize_arguments is False
     assert configured_func.show_result is True
     assert configured_func.stop_after_tool_call is True
     assert configured_func.requires_confirmation is True