support anthropic

Author: Zephyroam

camel/models/anthropic_model.py

@@ -14,7 +14,6 @@
 import json
 import os
 import time
-import warnings
 from typing import Any, Dict, List, Optional, Type, Union, cast
 
 from openai import AsyncStream, Stream
@@ -636,6 +635,37 @@ def _convert_anthropic_stream_to_openai_chunk(
             usage=usage,
         )
 
+    @staticmethod
+    def _add_additional_properties_false(schema: Dict[str, Any]) -> None:
+        r"""Recursively add additionalProperties: false to all object types."""
+        if schema.get("type") == "object":
+            schema["additionalProperties"] = False
+        for value in schema.values():
+            if isinstance(value, dict):
+                AnthropicModel._add_additional_properties_false(value)
+            elif isinstance(value, list):
+                for item in value:
+                    if isinstance(item, dict):
+                        AnthropicModel._add_additional_properties_false(item)
+
+    @staticmethod
+    def _build_output_config(
+        response_format: Type[BaseModel],
+    ) -> Dict[str, Any]:
+        r"""Convert a Pydantic model to Anthropic's output_config format."""
+        schema = response_format.model_json_schema()
+        # Remove unsupported fields
+        schema.pop("$defs", None)
+        schema.pop("definitions", None)
+        # Anthropic requires additionalProperties: false on all object types
+        AnthropicModel._add_additional_properties_false(schema)
+        return {
+            "format": {
+                "type": "json_schema",
+                "schema": schema,
+            }
+        }
+
     def _convert_openai_tools_to_anthropic(
         self, tools: Optional[List[Dict[str, Any]]]
     ) -> Optional[List[Dict[str, Any]]]:
@@ -678,7 +708,7 @@ def _run(
             messages (List[OpenAIMessage]): Message list with the chat history
                 in OpenAI API format.
             response_format (Optional[Type[BaseModel]]): The format of the
-                response. (Not supported by Anthropic API directly)
+                response.
             tools (Optional[List[Dict[str, Any]]]): The schema of the tools to
                 use for the request.
 
@@ -687,15 +717,6 @@ def _run(
                 `ChatCompletion` in the non-stream mode, or
                 `Stream[ChatCompletionChunk]` in the stream mode.
         """
-        if response_format is not None:
-            warnings.warn(
-                "The 'response_format' parameter is not supported by the "
-                "Anthropic API and will be ignored. Consider using tools "
-                "for structured output instead.",
-                UserWarning,
-                stacklevel=2,
-            )
-
         # Update Langfuse trace with current agent session and metadata
         agent_session_id = get_current_agent_session_id()
         if agent_session_id:
@@ -764,6 +785,12 @@ def _run(
             if key in self.model_config_dict:
                 request_params[key] = self.model_config_dict[key]
 
+        # Add structured output via output_config
+        if response_format is not None:
+            request_params["output_config"] = self._build_output_config(
+                response_format
+            )
+
         # Convert tools
         anthropic_tools = self._convert_openai_tools_to_anthropic(tools)
         if anthropic_tools:
@@ -803,7 +830,7 @@ async def _arun(
             messages (List[OpenAIMessage]): Message list with the chat history
                 in OpenAI API format.
             response_format (Optional[Type[BaseModel]]): The format of the
-                response. (Not supported by Anthropic API directly)
+                response.
             tools (Optional[List[Dict[str, Any]]]): The schema of the tools to
                 use for the request.
 
@@ -812,15 +839,6 @@ async def _arun(
                 `ChatCompletion` in the non-stream mode, or
                 `AsyncStream[ChatCompletionChunk]` in the stream mode.
         """
-        if response_format is not None:
-            warnings.warn(
-                "The 'response_format' parameter is not supported by the "
-                "Anthropic API and will be ignored. Consider using tools "
-                "for structured output instead.",
-                UserWarning,
-                stacklevel=2,
-            )
-
         # Update Langfuse trace with current agent session and metadata
         agent_session_id = get_current_agent_session_id()
         if agent_session_id:
@@ -889,6 +907,12 @@ async def _arun(
             if key in self.model_config_dict:
                 request_params[key] = self.model_config_dict[key]
 
+        # Add structured output via output_config
+        if response_format is not None:
+            request_params["output_config"] = self._build_output_config(
+                response_format
+            )
+
         # Convert tools
         anthropic_tools = self._convert_openai_tools_to_anthropic(tools)
         if anthropic_tools:

examples/agents/chatagent_stream_structured_output.py

@@ -30,10 +30,14 @@
 
 
 class Result(BaseModel):
-    sum_result: str = Field(description="Result of the addition")
-    product_result: str = Field(description="Result of the multiplication")
-    division_result: str = Field(description="Result of the division")
-    capital_result: str = Field(description="Result of the capital search")
+    sum_result: str = Field(description="Only the result of the addition")
+    product_result: str = Field(
+        description="Only the result of the multiplication"
+    )
+    division_result: str = Field(description="Only the result of the division")
+    capital_result: str = Field(
+        description="Only the result of the capital search"
+    )
 
 
 USER_MESSAGE = (