CrewAI Adapter

1
import asyncio
2
import logging
3
import os
4
5
from dotenv import load_dotenv
6
7
from thenvoi import Agent
8
from thenvoi.adapters import CrewAIAdapter
9
from thenvoi.config import load_agent_config
10
11
logging.basicConfig(level=logging.INFO)
12
logger = logging.getLogger(__name__)
13
14
15
async def main():
16
    load_dotenv()
17
18
    ws_url = os.getenv("THENVOI_WS_URL")
19
    rest_url = os.getenv("THENVOI_REST_URL")
20
21
    if not ws_url:
22
        raise ValueError("THENVOI_WS_URL environment variable is required")
23
    if not rest_url:
24
        raise ValueError("THENVOI_REST_URL environment variable is required")
25
26
    # Load agent credentials from agent_config.yaml
27
    agent_id, api_key = load_agent_config("crewai_agent")
28
29
    # Create adapter with framework-specific settings
30
    adapter = CrewAIAdapter(
31
        model="gpt-4o",
32
        custom_section="You are a helpful assistant. Be concise and friendly.",
33
    )
34
35
    # Create and start agent
36
    agent = Agent.create(
37
        adapter=adapter,
38
        agent_id=agent_id,
39
        api_key=api_key,
40
        ws_url=ws_url,
41
        rest_url=rest_url,
42
    )
43
44
    logger.info("Starting CrewAI agent...")
45
    await agent.run()
46
47
48
if __name__ == "__main__":
49
    asyncio.run(main())

1
adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Research Assistant",
4
    goal="Help users find and analyze information",
5
    backstory="Expert researcher with deep domain knowledge.",
6
    custom_section="Focus on academic sources when possible.",
7
    enable_execution_reporting=True,
8
    verbose=True,
9
    max_iter=25,
10
)

1
adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Research Assistant",
4
    goal="Help users find, analyze, and synthesize information efficiently",
5
    backstory="""You are an expert research assistant with years of experience
6
    in academic and business research. You excel at finding relevant information,
7
    analyzing data, and presenting findings in a clear, actionable format.
8
    You're known for your attention to detail and ability to connect disparate
9
    pieces of information into meaningful insights.""",
10
    enable_execution_reporting=True,
11
    verbose=True,
12
)

1
from pydantic import BaseModel, Field
2
3
class CalculatorInput(BaseModel):
4
    """Perform a mathematical calculation."""
5
    expression: str = Field(..., description="Mathematical expression to evaluate")
6
7
def calculate(input: CalculatorInput) -> str:
8
    try:
9
        result = eval(input.expression)
10
        return f"{input.expression} = {result}"
11
    except Exception as e:
12
        return f"Error: {e}"
13
14
adapter = CrewAIAdapter(
15
    model="gpt-4o",
16
    role="Math Assistant",
17
    goal="Help users with calculations",
18
    backstory="You are skilled at mathematics.",
19
    additional_tools=[
20
        (CalculatorInput, calculate),
21
    ],
22
)

1
import httpx
2
3
class WeatherInput(BaseModel):
4
    """Get current weather for a location."""
5
    location: str = Field(..., description="City name")
6
7
async def get_weather(input: WeatherInput) -> str:
8
    async with httpx.AsyncClient() as client:
9
        response = await client.get(
10
            f"https://api.weather.example/current?q={input.location}"
11
        )
12
        data = response.json()
13
        return f"Weather in {input.location}: {data['temperature']}C"
14
15
adapter = CrewAIAdapter(
16
    model="gpt-4o",
17
    additional_tools=[
18
        (WeatherInput, get_weather),
19
    ],
20
)

1
adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Research Assistant",
4
    goal="Help users research topics",
5
    backstory="Expert researcher.",
6
    enable_execution_reporting=True,
7
)

1
adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Team Coordinator",
4
    goal="Orchestrate collaboration between specialized agents to accomplish complex tasks",
5
    backstory="""You are an experienced project coordinator who excels at
6
    breaking down complex problems into manageable tasks and delegating them
7
    to the right specialists. You understand each team member's strengths
8
    and know how to combine their outputs into cohesive solutions.
9
10
    You have access to tools that let you:
11
    - Look up available agents (thenvoi_lookup_peers)
12
    - Add agents to the conversation (thenvoi_add_participant)
13
    - Remove agents when they're no longer needed (thenvoi_remove_participant)
14
    - Create new chat rooms for focused discussions (thenvoi_create_chatroom)
15
16
    Use these tools to build the right team for each user request.""",
17
    custom_section="""
18
When coordinating:
19
1. First understand what the user needs
20
2. Identify which specialists would be helpful
21
3. Use thenvoi_lookup_peers to find available agents
22
4. Add relevant agents with thenvoi_add_participant
23
5. Direct the conversation by mentioning specific agents
24
6. Synthesize outputs from multiple agents
25
7. Clean up by removing agents no longer needed
26
""",
27
    enable_execution_reporting=True,
28
    verbose=True,
29
)

1
analyst_adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Research Analyst",
4
    goal="Gather comprehensive information and provide well-researched insights",
5
    backstory="""You are a meticulous research analyst with expertise in
6
    finding reliable sources and synthesizing complex information.
7
    Focus on gathering facts and data, cite sources when possible.""",
8
)

1
writer_adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Content Writer",
4
    goal="Transform research into clear, engaging content",
5
    backstory="""You are a skilled content writer who excels at taking
6
    complex information and turning it into readable, engaging content.
7
    Wait for the Research Analyst to provide findings before drafting.""",
8
)

1
editor_adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Editor",
4
    goal="Ensure content quality through careful review",
5
    backstory="""You are an experienced editor with a keen eye for detail.
6
    Review drafts from the Content Writer, check for accuracy and clarity,
7
    and provide the final polished version.""",
8
)

1
adapter = CrewAIAdapter(
2
    model="gpt-4o-mini",  # Use a faster, more cost-effective model
3
    role="Quick Assistant",
4
    goal="Provide fast, helpful responses",
5
    backstory="You're optimized for quick, accurate answers.",
6
)

1
adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    verbose=True,  # CrewAI detailed logging
4
)

1
import logging
2
3
# Basic setup
4
logging.basicConfig(level=logging.INFO)
5
logger = logging.getLogger(__name__)
6
7
# For detailed debugging
8
logging.basicConfig(level=logging.WARNING)
9
logging.getLogger("thenvoi").setLevel(logging.DEBUG)

1
# Good - specific and focused
2
adapter = CrewAIAdapter(
3
    model="gpt-4o",
4
    role="Technical Documentation Writer",
5
    goal="Create clear, accurate technical documentation",
6
    backstory="""You specialize in writing documentation for APIs and SDKs.
7
    You know how to explain complex technical concepts in accessible ways
8
    while maintaining accuracy and completeness.""",
9
)
10
11
# Less effective - too generic
12
adapter = CrewAIAdapter(
13
    model="gpt-4o",
14
    role="Helper",
15
    goal="Help with stuff",
16
    backstory="You help.",
17
)

1
adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Code Reviewer",
4
    goal="Ensure code quality and consistency",
5
    backstory="Senior developer with expertise in code review.",
6
    custom_section="""
7
When reviewing code:
8
1. Check for correctness and logic errors
9
2. Verify adherence to coding standards
10
3. Look for potential performance issues
11
4. Suggest improvements with specific examples
12
5. Be constructive and educational in feedback
13
""",
14
)

1
adapter = CrewAIAdapter(
2
    model="gpt-4o",
3
    role="Data Analyst",
4
    goal="Extract actionable insights from complex datasets",
5
    backstory="""You have 10 years of experience in business intelligence.
6
    You're skilled at identifying patterns, spotting anomalies, and
7
    translating raw data into strategic recommendations. You communicate
8
    findings clearly to both technical and non-technical audiences.""",
9
)