CrewAI Example

from crewai import Agent, Crew, Task
from crewai.mcp import MCPServerHTTP
from composio import Composio

# Initialize Composio and create a session
composio = Composio()
session = composio.create(
    user_id="user_123",
)

# Create an agent with Composio MCP server
agent = Agent(
    role="Gmail agent",
    goal="helps with gmail related queries",
    backstory="You are a helpful assistant that can use the tools provided to you.",
    mcps=[
        MCPServerHTTP(
            url=session.mcp.url,
            headers=session.mcp.headers,
        )
    ],
)

# Define task
task = Task(
    description=("Find the last email and summarize it."),
    expected_output="A summary of the last email including sender, subject, and key points.",
    agent=agent,
)

# Create and run the crew
my_crew = Crew(agents=[agent], tasks=[task])
result = my_crew.kickoff()
print(result)

from crewai import Agent, Crew, Task, Process
from crewai.mcp import MCPServerHTTP
from composio import Composio

composio = Composio()
session = composio.create(user_id="user_123")

mcp_server = MCPServerHTTP(
    url=session.mcp.url,
    headers=session.mcp.headers,
)

# Email agent - handles email operations
email_agent = Agent(
    role="Email Specialist",
    goal="Manage and analyze emails efficiently",
    backstory="Expert in email management and communication",
    mcps=[mcp_server],
)

# Calendar agent - handles scheduling
calendar_agent = Agent(
    role="Calendar Manager",
    goal="Organize and optimize schedules",
    backstory="Expert in time management and scheduling",
    mcps=[mcp_server],
)

# Define tasks
email_task = Task(
    description="Find all unread emails from this week and create a summary",
    expected_output="A categorized summary of unread emails",
    agent=email_agent,
)

calendar_task = Task(
    description="Review this week's calendar and identify any scheduling conflicts",
    expected_output="A list of scheduling conflicts with suggested resolutions",
    agent=calendar_agent,
)

# Create crew with sequential process
crew = Crew(
    agents=[email_agent, calendar_agent],
    tasks=[email_task, calendar_task],
    process=Process.sequential,  # Tasks run in order
    verbose=True,
)

result = crew.kickoff()
print(result)

Starting crew execution...

[Gmail agent] Starting task: Find the last email and summarize it.
[Gmail agent] Using tool: gmail_get_latest_email
[Gmail agent] Task completed!

Result:
{
  "summary": {
    "from": "[email protected]",
    "subject": "Q1 Project Update",
    "received": "2 hours ago",
    "key_points": [
      "Project is on track for Q1 delivery",
      "Budget review scheduled for next week",
      "Team needs additional resources for testing phase"
    ]
  }
}

research_task = Task(
    description="Research the latest AI trends in email automation",
    expected_output="A detailed report on AI email automation trends",
    agent=researcher_agent,
)

write_task = Task(
    description="Write an email summary based on the research",
    expected_output="A professional email summarizing the findings",
    agent=writer_agent,
    context=[research_task],  # Uses output from research_task
)

send_task = Task(
    description="Send the email to the team",
    expected_output="Confirmation that email was sent",
    agent=email_agent,
    context=[write_task],  # Uses output from write_task
)

crew = Crew(
    agents=[researcher_agent, writer_agent, email_agent],
    tasks=[research_task, write_task, send_task],
    process=Process.sequential,
)

mcp_server = MCPServerHTTP(
    url=session.mcp.url,
    headers=session.mcp.headers,
    timeout=30,  # Request timeout in seconds
    retry_attempts=3,  # Number of retry attempts
)

try:
    crew = Crew(
        agents=[agent],
        tasks=[task],
        verbose=True,
    )
    result = crew.kickoff()
    print(f"Success: {result}")
except Exception as e:
    print(f"Crew execution failed: {e}")
    # Handle errors (e.g., authentication, network issues)