Observability for CrewAI with Opik

1
import os
2
import getpass
3
4
if "OPENAI_API_KEY" not in os.environ:
5
    os.environ["OPENAI_API_KEY"] = getpass.getpass("Enter your OpenAI API key: ")

1
from crewai import Agent, Crew, Task, Process
2
3
class YourCrewName:
4
    def agent_one(self) -> Agent:
5
        return Agent(
6
            role="Data Analyst",
7
            goal="Analyze data trends in the market",
8
            backstory="An experienced data analyst with a background in economics",
9
            verbose=True,
10
        )
11
12
    def agent_two(self) -> Agent:
13
        return Agent(
14
            role="Market Researcher",
15
            goal="Gather information on market dynamics",
16
            backstory="A diligent researcher with a keen eye for detail",
17
            verbose=True,
18
        )
19
20
    def task_one(self) -> Task:
21
        return Task(
22
            name="Collect Data Task",
23
            description="Collect recent market data and identify trends.",
24
            expected_output="A report summarizing key trends in the market.",
25
            agent=self.agent_one(),
26
        )
27
28
    def task_two(self) -> Task:
29
        return Task(
30
            name="Market Research Task",
31
            description="Research factors affecting market dynamics.",
32
            expected_output="An analysis of factors influencing the market.",
33
            agent=self.agent_two(),
34
        )
35
36
    def crew(self) -> Crew:
37
        return Crew(
38
            agents=[self.agent_one(), self.agent_two()],
39
            tasks=[self.task_one(), self.task_two()],
40
            process=Process.sequential,
41
            verbose=True,
42
        )

1
from opik.integrations.crewai import track_crewai
2
3
# Create the crew
4
my_crew = YourCrewName().crew()
5
6
track_crewai(project_name="crewai-integration-demo", crew=my_crew)
7
8
# Run the crew
9
result = my_crew.kickoff()
10
11
print(result)

1
import litellm
2
from crewai.flow.flow import Flow, start, listen
3
from opik.integrations.crewai import track_crewai
4
5
track_crewai(project_name="crewai-integration-demo")
6
7
class ExampleFlow(Flow):
8
    model = "gpt-4o-mini"
9
10
    @start()
11
    def generate_city(self):
12
        response = litellm.completion(
13
            model=self.model,
14
            messages=[{"role": "user", "content": "Return the name of a random city."}],
15
        )
16
        return response["choices"][0]["message"]["content"]
17
18
    @listen(generate_city)
19
    def generate_fun_fact(self, random_city):
20
        response = litellm.completion(
21
            model=self.model,
22
            messages=[{"role": "user", "content": f"Tell me a fun fact about {random_city}"}],
23
        )
24
        return response["choices"][0]["message"]["content"]
25
26
flow = ExampleFlow()
27
result = flow.kickoff()

1
from crewai import Agent, Crew, Task, Process
2
from opik.integrations.crewai import track_crewai
3
4
# Define your crew (using the example from above)
5
my_crew = YourCrewName().crew()
6
7
# Enable tracking with the crew instance (required for v1.0.0+)
8
track_crewai(project_name="crewai-integration-demo", crew=my_crew)
9
10
# Pass thread_id via opik_args
11
args_dict = {
12
    "trace": {
13
        "thread_id": "conversation-2",
14
    },
15
}
16
17
result = my_crew.kickoff(opik_args=args_dict)