# server.py 
import logging
from mcp.server.fastmcp import FastMCP
 
# Create an MCP server
mcp = FastMCP("Demo")
 

# create an error agent that raises an error
@mcp.tool() 
async def error_agent(task: str) -> str:
    """An agent that raises an error"""
    raise Exception("This is an error agent") 

if __name__ == "__main__":
    mcp.run()

from autogen_ext.models.openai import OpenAIChatCompletionClient
from autogen_ext.tools.mcp import StdioServerParams, mcp_server_tools
from autogen_agentchat.agents import AssistantAgent
from autogen_core import CancellationToken
from autogen_agentchat.ui import Console

async def main() -> None:
    # Setup server params for local filesystem access
    fetch_mcp_server = StdioServerParams(command="/pathtopython/python", args=["pathtoserver/server.py"])
    tools = await mcp_server_tools(fetch_mcp_server)

    # Create an agent that can use the fetch tool.
    model_client = OpenAIChatCompletionClient(model="gpt-4o")
    agent = AssistantAgent(name="fetcher", model_client=model_client, tools=tools, reflect_on_tool_use=True)   

    await Console(agent.run_stream(task="raise an error withthe errror agent", cancellation_token=CancellationToken()))
    
await main()