Merge branch 'main' into release/2.5.5

Author: ysolanky

cookbook/05_agent_os/approvals/approval_basic.py

@@ -0,0 +1,69 @@
+"""
+Approval Basic
+=============================
+
+Approval-backed HITL: @approval + @tool(requires_confirmation=True) with persistent DB record.
+"""
+
+import json
+import httpx
+
+from agno.agent import Agent
+from agno.approval import approval
+from agno.db.sqlite import SqliteDb
+from agno.models.openai import OpenAIResponses
+from agno.tools import tool
+from agno.os import AgentOS
+DB_FILE = "tmp/approvals_test.db"
+
+
+@approval(type="required")
+@tool(requires_confirmation=True)
+def get_top_hackernews_stories(num_stories: int) -> str:
+    """Fetch top stories from Hacker News.
+
+    Args:
+        num_stories (int): Number of stories to retrieve.
+
+    Returns:
+        str: JSON string of story details.
+    """
+    response = httpx.get("https://hacker-news.firebaseio.com/v0/topstories.json")
+    story_ids = response.json()
+    stories = []
+    for story_id in story_ids[:num_stories]:
+        story = httpx.get(
+            f"https://hacker-news.firebaseio.com/v0/item/{story_id}.json"
+        ).json()
+        story.pop("text", None)
+        stories.append(story)
+    return json.dumps(stories)
+
+
+# ---------------------------------------------------------------------------
+# Create Agent
+# ---------------------------------------------------------------------------
+db = SqliteDb(
+    db_file=DB_FILE, session_table="agent_sessions", approvals_table="approvals"
+)
+agent = Agent(
+    model=OpenAIResponses(id="gpt-5-mini"),
+    tools=[get_top_hackernews_stories],
+    markdown=True,
+    db=db,
+)
+
+
+agent_os = AgentOS(
+    description="Example app for tracing with multiple models, agents, teams, and workflows",
+    agents=[
+        agent,
+        ],
+        tracing=True,
+        db=db,
+        
+)
+app = agent_os.get_app()
+
+if __name__ == "__main__":
+    agent_os.serve(app="approval_basic:app", reload=True)

cookbook/05_agent_os/approvals/approval_user_input.py

@@ -0,0 +1,79 @@
+"""
+Approval User Input
+=============================
+
+Approval + user input HITL: @approval + @tool(requires_user_input=True).
+"""
+
+import os
+
+from agno.agent import Agent
+from agno.approval import approval
+from agno.db.sqlite import SqliteDb
+from agno.models.openai import OpenAIResponses
+from agno.os import AgentOS
+from agno.tools import tool
+DB_FILE = "tmp/approvals_test.db"
+
+
+@approval(type="required")
+@tool(requires_user_input=True, user_input_fields=["recipient", "note"])
+def send_money(amount: float, recipient: str, note: str) -> str:
+    """Send money to a recipient.
+
+    Args:
+        amount (float): The amount of money to send.
+        recipient (str): The recipient to send money to (provided by user).
+        note (str): A note to include with the transfer.
+
+    Returns:
+        str: Confirmation of the transfer.
+    """
+    return f"Sent ${amount} to {recipient}: {note}"
+
+
+# ---------------------------------------------------------------------------
+# Create Agent
+# ---------------------------------------------------------------------------
+db = SqliteDb(
+    db_file=DB_FILE, session_table="agent_sessions", approvals_table="approvals"
+)
+agent = Agent(
+    model=OpenAIResponses(id="gpt-5-mini"),
+    tools=[send_money],
+    markdown=True,
+    db=db,
+)
+
+# ---------------------------------------------------------------------------
+# Run Agent
+# ---------------------------------------------------------------------------
+if __name__ == "__main__":
+    # Clean up from previous runs
+    if os.path.exists(DB_FILE):
+        os.remove(DB_FILE)
+    os.makedirs("tmp", exist_ok=True)
+
+    # Re-create after cleanup
+    db = SqliteDb(
+        db_file=DB_FILE, session_table="agent_sessions", approvals_table="approvals"
+    )
+    agent = Agent(
+        model=OpenAIResponses(id="gpt-5-mini"),
+        tools=[send_money],
+        markdown=True,
+        db=db,
+    )
+agent_os = AgentOS(
+    description="Example app for tracing with multiple models, agents, teams, and workflows",
+    agents=[
+        agent,
+        ],
+        tracing=True,
+        db=db,
+        
+)
+app = agent_os.get_app()
+
+if __name__ == "__main__":
+    agent_os.serve(app="approval_user_input:app", reload=True)

libs/agno/tests/system/Dockerfile.gateway

@@ -37,7 +37,8 @@ RUN pip install --no-cache-dir \
     a2a-sdk \
     agui \
     ag-ui-protocol \
-    slack-sdk
+    slack-sdk \
+    aiohttp
 
 # Copy the gateway server script
 WORKDIR /app