update other examples in plugin folder

Author: tschellenbach

agents-core/pyproject.toml

@@ -82,7 +82,7 @@ packages = ["vision_agents"]
 [tool.hatch.build.targets.sdist]
 include = ["vision_agents"]
 
-#[tool.uv.sources]
+[tool.uv.sources]
 #krisp-audio = [
 #    { path = "./vision_agents/core/turn_detection/krisp/krisp_audio-1.4.0-cp313-cp313-macosx_12_0_arm64.whl", marker = "sys_platform == 'darwin' and platform_machine == 'aarch64'" },
 #    { path = "./vision_agents/core/turn_detection/krisp/krisp_audio-1.4.0-cp313-cp313-linux_aarch64.whl", marker = "sys_platform == 'linux' and platform_machine == 'aarch64'" },
@@ -91,5 +91,5 @@ include = ["vision_agents"]
 #]
 # getstream = { git = "https://github.com/GetStream/stream-py.git", branch = "audio-more" }
 # for local development
-# getstream = { path = "../../stream-py/", editable = true }
+getstream = { path = "../../stream-py/", editable = true }
 # aiortc = { path = "../stream-py/", editable = true }

plugins/aws/example/aws_llm_function_calling_example.py

@@ -1,32 +1,37 @@
+"""
+AWS Bedrock LLM with Function Calling Example
+
+This example demonstrates using AWS Bedrock LLM with streaming and function calling.
+The agent can call custom functions to get weather information and perform calculations.
+"""
+
 import asyncio
 import logging
-from uuid import uuid4
 
 from dotenv import load_dotenv
 
-from vision_agents.core import User
-from vision_agents.core.agents import Agent
+from vision_agents.core import User, Agent, cli
+from vision_agents.core.agents import AgentLauncher
 from vision_agents.plugins import aws, getstream, cartesia, deepgram
 
-load_dotenv()
 
-logging.basicConfig(level=logging.INFO, format="%(asctime)s %(levelname)s [call_id=%(call_id)s] %(name)s: %(message)s")
 logger = logging.getLogger(__name__)
 
+load_dotenv()
+
 
-async def start_agent() -> None:
+async def create_agent(**kwargs) -> Agent:
+    """Create the agent with AWS Bedrock LLM."""
     agent = Agent(
         edge=getstream.Edge(),
-        agent_user=User(name="Weather Bot"),
+        agent_user=User(name="Weather Bot", id="agent"),
         instructions="You are a helpful weather bot. Use the provided tools to answer questions.",
         llm=aws.LLM(
             model="anthropic.claude-3-sonnet-20240229-v1:0",
             region_name="us-east-1"
-
         ),
         tts=cartesia.TTS(),
         stt=deepgram.STT(),
-        # turn_detection=smart_turn.TurnDetection(buffer_duration=2.0, confidence_threshold=0.5),
     )
 
     # Register custom functions
@@ -54,12 +59,25 @@ def calculate(expression: str) -> dict:
         except Exception as e:
             return {"expression": expression, "error": str(e)}
 
+    return agent
+
+
+async def join_call(agent: Agent, call_type: str, call_id: str, **kwargs) -> None:
+    """Join the call and start the agent."""
+    # Ensure the agent user is created
     await agent.create_user()
+    # Create a call
+    call = await agent.create_call(call_type, call_id)
+
+    logger.info("🤖 Starting AWS Bedrock LLM Agent...")
 
-    call = agent.edge.client.video.call("default", str(uuid4()))
-    await agent.edge.open_demo(call)
-    
+    # Have the agent join the call/room
     with await agent.join(call):
+        logger.info("Joining call")
+
+        await agent.edge.open_demo(call)
+        logger.info("LLM ready")
+        
         # Give the agent a moment to connect
         await asyncio.sleep(5)
 
@@ -81,9 +99,9 @@ def calculate(expression: str) -> dict:
 
         # Wait a bit before finishing
         await asyncio.sleep(5)
-        await agent.finish()
+        await agent.finish()  # Run till the call ends
 
 
 if __name__ == "__main__":
-    asyncio.run(start_agent())
+    cli(AgentLauncher(create_agent=create_agent, join_call=join_call))
 

plugins/aws/example/aws_qwen_example.py

@@ -1,40 +1,59 @@
+"""
+AWS Bedrock Qwen LLM Example
+
+This example demonstrates using AWS Bedrock with the Qwen LLM model.
+"""
+
 import asyncio
 import logging
-from uuid import uuid4
 
 from dotenv import load_dotenv
 
-from vision_agents.core import User
-from vision_agents.core.agents import Agent
+from vision_agents.core import User, Agent, cli
+from vision_agents.core.agents import AgentLauncher
 from vision_agents.plugins import aws, getstream, cartesia, deepgram, smart_turn
 
-load_dotenv()
 
-logging.basicConfig(level=logging.INFO, format="%(asctime)s %(levelname)s [call_id=%(call_id)s] %(name)s: %(message)s")
 logger = logging.getLogger(__name__)
 
+load_dotenv()
+
 
-async def start_agent() -> None:
+async def create_agent(**kwargs) -> Agent:
+    """Create the agent with AWS Bedrock Qwen LLM."""
     agent = Agent(
         edge=getstream.Edge(),
-        agent_user=User(name="Friendly AI"),
+        agent_user=User(name="Friendly AI", id="agent"),
         instructions="Be nice to the user",
         llm=aws.LLM(model="qwen.qwen3-32b-v1:0"),
         tts=cartesia.TTS(),
         stt=deepgram.STT(),
         turn_detection=smart_turn.TurnDetection(buffer_in_seconds=2.0, confidence_threshold=0.5),
-        # Enable turn detection with FAL/ Smart turn
     )
+    return agent
+
+
+async def join_call(agent: Agent, call_type: str, call_id: str, **kwargs) -> None:
+    """Join the call and start the agent."""
+    # Ensure the agent user is created
     await agent.create_user()
+    # Create a call
+    call = await agent.create_call(call_type, call_id)
 
-    call = agent.edge.client.video.call("default", str(uuid4()))
-    await agent.edge.open_demo(call)
+    logger.info("🤖 Starting AWS Qwen Agent...")
 
+    # Have the agent join the call/room
     with await agent.join(call):
+        logger.info("Joining call")
+
+        await agent.edge.open_demo(call)
+        logger.info("LLM ready")
+        
         await asyncio.sleep(5)
         await agent.llm.simple_response(text="Say hi")
-        await agent.finish()
+        
+        await agent.finish()  # Run till the call ends
 
 
 if __name__ == "__main__":
-    asyncio.run(start_agent())
+    cli(AgentLauncher(create_agent=create_agent, join_call=join_call))

plugins/aws/example/aws_realtime_function_calling_example.py

@@ -1,33 +1,30 @@
+"""
+AWS Bedrock Realtime with Function Calling Example
+
+This example creates an agent that can call custom functions to get
+weather information and perform calculations.
+"""
+
 import asyncio
 import logging
-from uuid import uuid4
 
 from dotenv import load_dotenv
 
-from vision_agents.core import User
-from vision_agents.core.agents import Agent
+from vision_agents.core import User, Agent, cli
+from vision_agents.core.agents import AgentLauncher
 from vision_agents.plugins import aws, getstream
 
-load_dotenv()
 
-logging.basicConfig(
-    level=logging.INFO,
-    format="%(asctime)s %(levelname)s [call_id=%(call_id)s] %(name)s: %(message)s"
-)
 logger = logging.getLogger(__name__)
 
+load_dotenv()
+
 
-async def start_agent() -> None:
-    """Example demonstrating AWS Bedrock realtime with function calling.
-    
-    This example creates an agent that can call custom functions to get
-    weather information and perform calculations.
-    """
-    
-    # Create the agent with AWS Bedrock Realtime
+async def create_agent(**kwargs) -> Agent:
+    """Create the agent with AWS Bedrock Realtime."""
     agent = Agent(
         edge=getstream.Edge(),
-        agent_user=User(name="Weather Assistant AI"),
+        agent_user=User(name="Weather Assistant AI", id="agent"),
         instructions="""You are a helpful weather assistant. When users ask about weather,
         use the get_weather function to fetch current conditions. You can also help with
         simple calculations using the calculate function.""",
@@ -103,13 +100,25 @@ def calculate(operation: str, a: float, b: float) -> dict:
             "result": result
         }
 
-    # Create and start the agent
+    return agent
+
+
+async def join_call(agent: Agent, call_type: str, call_id: str, **kwargs) -> None:
+    """Join the call and start the agent."""
+    # Ensure the agent user is created
     await agent.create_user()
-    
-    call = agent.edge.client.video.call("default", str(uuid4()))
-    await agent.edge.open_demo(call)
-    
+    # Create a call
+    call = await agent.create_call(call_type, call_id)
+
+    logger.info("🤖 Starting AWS Bedrock Realtime Agent...")
+
+    # Have the agent join the call/room
     with await agent.join(call):
+        logger.info("Joining call")
+
+        await agent.edge.open_demo(call)
+        logger.info("LLM ready")
+        
         # Give the agent a moment to connect
         await asyncio.sleep(5)
 
@@ -120,9 +129,9 @@ def calculate(operation: str, a: float, b: float) -> dict:
         # Wait for AWS Nova to process the request and call the function
         await asyncio.sleep(15)
 
-        await agent.finish()
+        await agent.finish()  # Run till the call ends
 
 
 if __name__ == "__main__":
-    asyncio.run(start_agent())
+    cli(AgentLauncher(create_agent=create_agent, join_call=join_call))
 

plugins/aws/example/aws_realtime_nova_example.py

@@ -1,36 +1,56 @@
+"""
+AWS Bedrock Realtime Nova Example
+
+This example demonstrates using AWS Bedrock Realtime with the Nova model.
+"""
+
 import asyncio
 import logging
-from uuid import uuid4
 
 from dotenv import load_dotenv
 
-from vision_agents.core import User
-from vision_agents.core.agents import Agent
+from vision_agents.core import User, Agent, cli
+from vision_agents.core.agents import AgentLauncher
 from vision_agents.plugins import aws, getstream
 
-load_dotenv()
 
-logging.basicConfig(level=logging.INFO, format="%(asctime)s %(levelname)s [call_id=%(call_id)s] %(name)s: %(message)s")
 logger = logging.getLogger(__name__)
 
+load_dotenv()
+
 
-async def start_agent() -> None:
+async def create_agent(**kwargs) -> Agent:
+    """Create the agent with AWS Bedrock Realtime."""
     agent = Agent(
         edge=getstream.Edge(),
-        agent_user=User(name="Story Teller AI"),
+        agent_user=User(name="Story Teller AI", id="agent"),
         instructions="Tell a story suitable for a 7 year old about a dragon and a princess",
         llm=aws.Realtime(),
     )
+    return agent
+
+
+async def join_call(agent: Agent, call_type: str, call_id: str, **kwargs) -> None:
+    """Join the call and start the agent."""
+    # Ensure the agent user is created
     await agent.create_user()
+    # Create a call
+    call = await agent.create_call(call_type, call_id)
 
-    call = agent.edge.client.video.call("default", str(uuid4()))
-    await agent.edge.open_demo(call)
+    logger.info("🤖 Starting AWS Realtime Nova Agent...")
 
+    # Have the agent join the call/room
     with await agent.join(call):
+        logger.info("Joining call")
+
+        await agent.edge.open_demo(call)
+        logger.info("LLM ready")
+        
         await asyncio.sleep(5)
         await agent.llm.simple_response(text="Say hi and start the story")
-        await agent.finish()
+        
+        await agent.finish()  # Run till the call ends
 
 
 if __name__ == "__main__":
-    asyncio.run(start_agent())
+    cli(AgentLauncher(create_agent=create_agent, join_call=join_call))