CrewAI Integration with Veritrix Agent Observability

from crewai import Agent, Task, Crew
from crewai_tools import SerperDevTool
from veritrix import trace

trace.init("research-crew")

search_tool = SerperDevTool()

researcher = Agent(
    role="Senior Research Analyst",
    goal="Find accurate and up-to-date information on the given topic.",
    backstory="You are an expert researcher with a talent for finding reliable sources.",
    tools=[search_tool],
    verbose=True,
)

writer = Agent(
    role="Technical Writer",
    goal="Synthesize research findings into a clear, concise summary.",
    backstory="You specialize in turning complex research into accessible writing.",
    verbose=True,
)

research_task = Task(
    description="Research the latest developments in AI agent observability.",
    expected_output="A list of key findings with sources.",
    agent=researcher,
)

writing_task = Task(
    description="Write a two-paragraph summary of the research findings.",
    expected_output="A polished two-paragraph summary.",
    agent=writer,
)

crew = Crew(
    agents=[researcher, writer],
    tasks=[research_task, writing_task],
    verbose=True,
)

result = crew.kickoff()
print(result)

from crewai.flow.flow import Flow, listen, start
from veritrix import trace

trace.init("content-flow")

class ContentFlow(Flow):
    @start()
    def generate_outline(self):
        return "Introduction, Main Body, Conclusion"

    @listen(generate_outline)
    def write_draft(self, outline: str):
        # In a real flow, an LLM or crew would expand the outline
        return f"Draft based on: {outline}"

flow = ContentFlow()
result = flow.kickoff()
print(result)