Merge branch 'release/1.6.0' of https://github.com/agno-agi/agno into release/1.6.0

Author: dirkbrnd

cookbook/agent_concepts/events/basic_agent_events.py

@@ -0,0 +1,49 @@
+import asyncio
+
+from agno.agent import RunEvent
+from agno.agent.agent import Agent
+from agno.models.openai.chat import OpenAIChat
+from agno.tools.yfinance import YFinanceTools
+
+finance_agent = Agent(
+    agent_id="finance-agent",
+    name="Finance Agent",
+    model=OpenAIChat(id="gpt-4o"),
+    tools=[YFinanceTools()],
+)
+
+
+async def run_agent_with_events(prompt: str):
+    content_started = False
+    async for run_response_event in await finance_agent.arun(
+        prompt,
+        stream=True,
+        stream_intermediate_steps=True,
+    ):
+        if run_response_event.event in [RunEvent.run_started, RunEvent.run_completed]:
+            print(f"\nEVENT: {run_response_event.event}")
+
+        if run_response_event.event in [RunEvent.tool_call_started]:
+            print(f"\nEVENT: {run_response_event.event}")
+            print(f"TOOL CALL: {run_response_event.tool.tool_name}")
+            print(f"TOOL CALL ARGS: {run_response_event.tool.tool_args}")
+
+        if run_response_event.event in [RunEvent.tool_call_completed]:
+            print(f"\nEVENT: {run_response_event.event}")
+            print(f"TOOL CALL: {run_response_event.tool.tool_name}")
+            print(f"TOOL CALL RESULT: {run_response_event.tool.result}")
+
+        if run_response_event.event in [RunEvent.run_response_content]:
+            if not content_started:
+                print("\nCONTENT:")
+                content_started = True
+            else:
+                print(run_response_event.content, end="")
+
+
+if __name__ == "__main__":
+    asyncio.run(
+        run_agent_with_events(
+            "What is the price of Apple stock?",
+        )
+    )

cookbook/agent_concepts/events/reasoning_agent_events.py

@@ -0,0 +1,52 @@
+import asyncio
+
+from agno.agent import RunEvent
+from agno.agent.agent import Agent
+from agno.models.openai.chat import OpenAIChat
+
+finance_agent = Agent(
+    model=OpenAIChat(id="gpt-4o"),
+    reasoning=True,
+)
+
+
+async def run_agent_with_events(prompt: str):
+    content_started = False
+    async for run_response_event in await finance_agent.arun(
+        prompt,
+        stream=True,
+        stream_intermediate_steps=True,
+    ):
+        if run_response_event.event in [RunEvent.run_started, RunEvent.run_completed]:
+            print(f"\nEVENT: {run_response_event.event}")
+
+        if run_response_event.event in [RunEvent.reasoning_started]:
+            print(f"\nEVENT: {run_response_event.event}")
+
+        if run_response_event.event in [RunEvent.reasoning_step]:
+            print(f"\nEVENT: {run_response_event.event}")
+            print(f"REASONING CONTENT: {run_response_event.reasoning_content}")
+
+        if run_response_event.event in [RunEvent.reasoning_completed]:
+            print(f"\nEVENT: {run_response_event.event}")
+
+        if run_response_event.event in [RunEvent.run_response_content]:
+            if not content_started:
+                print("\nCONTENT:")
+                content_started = True
+            else:
+                print(run_response_event.content, end="")
+
+
+if __name__ == "__main__":
+    task = (
+        "Analyze the key factors that led to the signing of the Treaty of Versailles in 1919. "
+        "Discuss the political, economic, and social impacts of the treaty on Germany and how it "
+        "contributed to the onset of World War II. Provide a nuanced assessment that includes "
+        "multiple historical perspectives."
+    )
+    asyncio.run(
+        run_agent_with_events(
+            task,
+        )
+    )

cookbook/examples/streamlit_apps/agentic_rag/app.py

@@ -300,8 +300,8 @@ def main():
                     run_response = agentic_rag_agent.run(question, stream=True)
                     for _resp_chunk in run_response:
                         # Display tool calls if available
-                        if _resp_chunk.tools and len(_resp_chunk.tools) > 0:
-                            display_tool_calls(tool_calls_container, _resp_chunk.tools)
+                        if hasattr(_resp_chunk, "tool") and _resp_chunk.tool:
+                            display_tool_calls(tool_calls_container, [_resp_chunk.tool])
 
                         # Display response
                         if _resp_chunk.content is not None:

cookbook/examples/streamlit_apps/agentic_rag/requirements.txt

@@ -1,6 +1,6 @@
 # This file was autogenerated by uv via the following command:
 #    ./generate_requirements.sh
-agno==1.4.5
+agno==1.6.0
     # via -r cookbook/examples/apps/agentic_rag/requirements.in
 altair==5.5.0
     # via streamlit

cookbook/examples/streamlit_apps/agentic_rag/utils.py

@@ -3,6 +3,7 @@
 import streamlit as st
 from agentic_rag import get_agentic_rag_agent
 from agno.agent import Agent
+from agno.models.response import ToolExecution
 from agno.utils.log import logger
 
 
@@ -38,7 +39,7 @@ def export_chat_history():
     return ""
 
 
-def display_tool_calls(tool_calls_container, tools):
+def display_tool_calls(tool_calls_container, tools: List[ToolExecution]):
     """Display tool calls in a streamlit container with expandable sections.
 
     Args:
@@ -51,19 +52,10 @@ def display_tool_calls(tool_calls_container, tools):
     with tool_calls_container.container():
         for tool_call in tools:
             # Handle different tool call formats
-            _tool_name = (
-                tool_call.get("tool_name") or tool_call.get("name") or "Unknown Tool"
-            )
-            _tool_args = tool_call.get("tool_args") or tool_call.get("arguments") or {}
-            _content = tool_call.get("content") or tool_call.get("result", "")
-            _metrics = tool_call.get("metrics", {})
-
-            # Handle function objects
-            if hasattr(tool_call, "function") and tool_call.function:
-                if hasattr(tool_call.function, "name"):
-                    _tool_name = tool_call.function.name
-                if hasattr(tool_call.function, "arguments"):
-                    _tool_args = tool_call.function.arguments
+            _tool_name = tool_call.tool_name or "Unknown Tool"
+            _tool_args = tool_call.tool_args or {}
+            _content = tool_call.result or ""
+            _metrics = tool_call.metrics or {}
 
             # Safely create the title with a default if tool name is None
             title = f"🛠️ {_tool_name.replace('_', ' ').title() if _tool_name else 'Tool Call'}"
@@ -101,7 +93,9 @@ def display_tool_calls(tool_calls_container, tools):
 
                 if _metrics:
                     st.markdown("**Metrics:**")
-                    st.json(_metrics)
+                    st.json(
+                        _metrics if isinstance(_metrics, dict) else _metrics._to_dict()
+                    )
 
 
 def rename_session_widget(agent: Agent) -> None:

cookbook/examples/streamlit_apps/answer_engine/app.py

@@ -177,8 +177,8 @@ def main() -> None:
                     run_response = sage.run(question, stream=True)
                     for _resp_chunk in run_response:
                         # Display tool calls if available
-                        if _resp_chunk.tools and len(_resp_chunk.tools) > 0:
-                            display_tool_calls(tool_calls_container, _resp_chunk.tools)
+                        if hasattr(_resp_chunk, "tool") and _resp_chunk.tool:
+                            display_tool_calls(tool_calls_container, [_resp_chunk.tool])
 
                         # Display response
                         if _resp_chunk.content is not None:

cookbook/examples/streamlit_apps/answer_engine/requirements.txt

@@ -1,6 +1,6 @@
 # This file was autogenerated by uv via the following command:
 #    ./generate_requirements.sh
-agno==1.1.11
+agno==1.6.0
     # via -r cookbook/examples/apps/answer_engine/requirements.in
 altair==5.5.0
     # via streamlit

cookbook/examples/streamlit_apps/answer_engine/utils.py

@@ -3,6 +3,7 @@
 import streamlit as st
 from agents import get_sage
 from agno.agent.agent import Agent
+from agno.models.response import ToolExecution
 from agno.utils.log import logger
 
 
@@ -39,7 +40,7 @@ def export_chat_history():
     return ""
 
 
-def display_tool_calls(tool_calls_container, tools):
+def display_tool_calls(tool_calls_container, tools: List[ToolExecution]):
     """Display tool calls in a streamlit container with expandable sections.
 
     Args:
@@ -49,10 +50,10 @@ def display_tool_calls(tool_calls_container, tools):
     try:
         with tool_calls_container.container():
             for tool_call in tools:
-                tool_name = tool_call.get("tool_name", "Unknown Tool")
-                tool_args = tool_call.get("tool_args", {})
-                content = tool_call.get("content")
-                metrics = tool_call.get("metrics", {})
+                tool_name = tool_call.tool_name or "Unknown Tool"
+                tool_args = tool_call.tool_args or {}
+                content = tool_call.result or ""
+                metrics = tool_call.metrics or {}
 
                 # Add timing information
                 execution_time_str = "N/A"

cookbook/examples/streamlit_apps/chess_team/requirements.txt

@@ -1,6 +1,6 @@
 # This file was autogenerated by uv via the following command:
 #    ./generate_requirements.sh
-agno==1.1.17
+agno==1.6.0
     # via -r cookbook/examples/apps/chess_team/requirements.in
 altair==5.5.0
     # via streamlit

cookbook/examples/streamlit_apps/gemini-tutor/requirements.txt

@@ -1,6 +1,6 @@
 # This file was autogenerated by uv via the following command:
 #    ./generate_requirements.sh
-agno==1.3.2
+agno==1.6.0
     # via -r cookbook/examples/apps/gemini-tutor/requirements.in
 altair==5.5.0
     # via streamlit