chore: Release 2.0.3 (#4529)

# Changelog

## New Features:

- **WorkflowTools**: Added `WorkflowTools` as a tool for agents and
teams that allows the agent/team to run a workflow. Also has reasoning
support for think/analyze.
- **MemoryTools**: Added `MemoryTools` as a tool for agents and teams to
add, update, delete memories. Also has reasoning support for
think/analyze.
- **Gemini TTS**: Added support for Gemini Text to Speech.
- Added support for `encoding` to be passed on reader class.

## Improvements:

- **AgentOS `kwargs` on runs:** Added support for additional arguments
on running an agent/team/workflow via `AgentOS` API.

## Bug Fixes:

- **Cerebras:** Fixed issues with `parallel_tool_calls` in Cerebras
model.
- **OpenAIResponses:** Fixed a bug with `store=False` in
`OpenAIResponses` class.
- **AgentOS Slack Interface**: the events endpoint was wrongly exposed
on `slack/slack/events`, it is now exposed on `slack/events`
- **AgentOS WhatsApp Interface:** fixed a bug where some messages
wouldn’t be sent.
- **Team MemoryManager**: Added `memory_manager` parameter to Teams.
- **FixedSizeChunking:** Default chunk_size increased to 5000.
- **Parser Model output in `print_response_stream`:** In streaming case
the structured output from parser model was not being displayed json
formatted in cli.

---------

Co-authored-by: Kaustubh <[email protected]>
Co-authored-by: Dirk Brand <[email protected]>

Author: 3 people

cookbook/memory/08_memory_tools.py

@@ -29,6 +29,7 @@
         "You are a trip planner bot and you are helping the user plan their trip.",
         "You should use the DuckDuckGoTools to get information about the destination and activities.",
         "You should use the MemoryTools to store information about the user for future reference.",
+        "Don't ask the user for more information, make up what you don't know.",
     ],
     markdown=True,
 )

cookbook/models/anthropic/web_fetch.py

@@ -5,7 +5,6 @@
     model=Claude(
         id="claude-opus-4-1-20250805",
         default_headers={"anthropic-beta": "web-fetch-2025-09-10"},
-
     ),
     tools=[
         {
@@ -17,4 +16,7 @@
     markdown=True,
 )
 
-agent.print_response("Tell me more about https://en.wikipedia.org/wiki/Glacier_National_Park_(U.S.)", stream=True)
+agent.print_response(
+    "Tell me more about https://en.wikipedia.org/wiki/Glacier_National_Park_(U.S.)",
+    stream=True,
+)

cookbook/models/openai/responses/reasoning_o3_mini.py

@@ -4,7 +4,7 @@
 
 agent = Agent(
     model=OpenAIResponses(id="o3-mini"),
-    tools=[YFinanceTools(enable_all=True)],
+    tools=[YFinanceTools()],
     markdown=True,
 )
 

cookbook/workflows/_06_advanced_concepts/_06_other/workflow_tools.py

@@ -99,41 +99,40 @@ def prepare_input_for_writer(step_input: StepInput) -> StepOutput:
 
 
 # Create and use workflow
-if __name__ == "__main__":
-    content_creation_workflow = Workflow(
-        name="Blog Post Workflow",
-        description="Automated blog post creation from Hackernews and the web",
-        db=SqliteDb(
-            session_table="workflow_session",
-            db_file="tmp/workflow.db",
-        ),
-        steps=[
-            prepare_input_for_web_search,
-            research_team,
-            prepare_input_for_writer,
-            writer_agent,
-        ],
-    )
+content_creation_workflow = Workflow(
+    name="Blog Post Workflow",
+    description="Automated blog post creation from Hackernews and the web",
+    db=SqliteDb(
+        session_table="workflow_session",
+        db_file="tmp/workflow.db",
+    ),
+    steps=[
+        prepare_input_for_web_search,
+        research_team,
+        prepare_input_for_writer,
+        writer_agent,
+    ],
+)
 
-    workflow_tools = WorkflowTools(
-        workflow=content_creation_workflow,
-        add_few_shot=True,
-        few_shot_examples=FEW_SHOT_EXAMPLES,
-        async_mode=True,
-    )
+workflow_tools = WorkflowTools(
+    workflow=content_creation_workflow,
+    add_few_shot=True,
+    few_shot_examples=FEW_SHOT_EXAMPLES,
+    async_mode=True,
+)
 
-    agent = Agent(
-        model=OpenAIChat(id="gpt-5-mini"),
-        tools=[workflow_tools],
-        markdown=True,
-    )
+agent = Agent(
+    model=OpenAIChat(id="gpt-5-mini"),
+    tools=[workflow_tools],
+    markdown=True,
+)
 
-    asyncio.run(
-        agent.aprint_response(
-            "Create a blog post with the following title: Quantum Computing in 2025",
-            instructions="When you run the workflow using the `run_workflow` tool, remember to pass `additional_data` as a dictionary of key-value pairs.",
-            markdown=True,
-            stream=True,
-            debug_mode=True,
-        )
+asyncio.run(
+    agent.aprint_response(
+        "Create a blog post with the following title: Quantum Computing in 2025",
+        instructions="When you run the workflow using the `run_workflow` tool, remember to pass `additional_data` as a dictionary of key-value pairs.",
+        markdown=True,
+        stream=True,
+        debug_mode=True,
     )
+)

libs/agno/agno/models/openai/responses.py

@@ -879,7 +879,7 @@ def _parse_provider_response(self, response: Response, **kwargs) -> ModelRespons
 
         # Add role
         model_response.role = "assistant"
-        reasoning_summary: str = ""
+        reasoning_summary: Optional[str] = None
 
         for output in response.output:
             # Add content

libs/agno/agno/run/agent.py

@@ -536,7 +536,7 @@ def to_dict(self) -> Dict[str, Any]:
 
         return _dict
 
-    def to_json(self, separators=(",", ":"), indent: Optional[int] = 2) -> str:
+    def to_json(self, separators=(", ", ": "), indent: Optional[int] = 2) -> str:
         import json
 
         try:

libs/agno/agno/run/base.py

@@ -115,7 +115,7 @@ def to_dict(self) -> Dict[str, Any]:
 
         return _dict
 
-    def to_json(self, separators=(",", ":"), indent: Optional[int] = 2) -> str:
+    def to_json(self, separators=(", ", ": "), indent: Optional[int] = 2) -> str:
         import json
 
         try:

libs/agno/agno/run/team.py

@@ -489,7 +489,7 @@ def to_dict(self) -> Dict[str, Any]:
 
         return _dict
 
-    def to_json(self, separators=(",", ":"), indent: Optional[int] = 2) -> str:
+    def to_json(self, separators=(", ", ": "), indent: Optional[int] = 2) -> str:
         import json
 
         try:

libs/agno/agno/run/workflow.py

@@ -91,7 +91,7 @@ def to_dict(self) -> Dict[str, Any]:
 
         return _dict
 
-    def to_json(self, separators=(",", ":"), indent: Optional[int] = 2) -> str:
+    def to_json(self, separators=(", ", ": "), indent: Optional[int] = 2) -> str:
         import json
 
         try:

libs/agno/agno/tools/memory.py

@@ -13,6 +13,7 @@ class MemoryTools(Toolkit):
     def __init__(
         self,
         db: BaseDb,
+        enable_get_memories: bool = True,
         enable_add_memory: bool = True,
         enable_update_memory: bool = True,
         enable_delete_memory: bool = True,
@@ -42,6 +43,8 @@ def __init__(
         tools: List[Any] = []
         if enable_think or all:
             tools.append(self.think)
+        if enable_get_memories or all:
+            tools.append(self.get_memories)
         if enable_add_memory or all:
             tools.append(self.add_memory)
         if enable_update_memory or all:
@@ -90,6 +93,20 @@ def think(self, session_state: Dict[str, Any], thought: str) -> str:
             log_error(f"Error recording memory thought: {e}")
             return f"Error recording memory thought: {e}"
 
+    def get_memories(self, session_state: Dict[str, Any]) -> str:
+        """
+        Use this tool to get a list of memories from the database.
+        """
+        try:
+            # Get user info from session state
+            user_id = session_state.get("current_user_id") if session_state else None
+
+            memories = self.db.get_user_memories(user_id=user_id)
+            return json.dumps([memory.to_dict() for memory in memories], indent=2)  # type: ignore
+        except Exception as e:
+            log_error(f"Error getting memories: {e}")
+            return json.dumps({"error": str(e)}, indent=2)
+
     def add_memory(
         self,
         session_state: Dict[str, Any],