CrewAI

1
import os
2
from dotenv import load_dotenv
3
4
load_dotenv()
5
6
from respan import Respan
7
from respan_instrumentation_openinference import OpenInferenceInstrumentor
8
from openinference.instrumentation.crewai import CrewAIInstrumentor
9
from crewai import Agent, Task, Crew
10
11
# Initialize Respan with CrewAI instrumentation
12
respan = Respan(
13
    instrumentations=[
14
        OpenInferenceInstrumentor(instrumentor=CrewAIInstrumentor())
15
    ]
16
)
17
18
# Define agents
19
researcher = Agent(
20
    role="Researcher",
21
    goal="Research and summarize the latest AI trends",
22
    backstory="You are a senior AI researcher with years of experience.",
23
)
24
25
writer = Agent(
26
    role="Writer",
27
    goal="Write a concise report based on the research",
28
    backstory="You are a technical writer who excels at clear communication.",
29
)
30
31
# Define tasks
32
research_task = Task(
33
    description="Research the latest trends in AI agent frameworks.",
34
    expected_output="A summary of key trends and developments.",
35
    agent=researcher,
36
)
37
38
write_task = Task(
39
    description="Write a brief report based on the research findings.",
40
    expected_output="A well-structured report in markdown format.",
41
    agent=writer,
42
)
43
44
# Create and run the crew
45
crew = Crew(
46
    agents=[researcher, writer],
47
    tasks=[research_task, write_task],
48
)
49
50
result = crew.kickoff()
51
print(result)
52
respan.flush()