from crewai import Agent, Crew, Process, Task
import cascadeflow
from cascadeflow.integrations.crewai import CrewAIHarnessConfig, enable
cascadeflow.init(mode="observe")
# Enable harness hooks
config = CrewAIHarnessConfig(
fail_open=True,
budget_gate=True,
)
enable(config=config)
# Define agents and tasks as usual
researcher = Agent(
role="Researcher",
goal="Find relevant information",
llm="gpt-4o-mini",
)
task = Task(
description="Research the topic of AI agent frameworks",
agent=researcher,
)
crew = Crew(
agents=[researcher],
tasks=[task],
process=Process.sequential,
)
# Run with budget tracking
with cascadeflow.run(budget=1.00) as session:
result = crew.kickoff()
print(session.summary())
for record in session.trace():
print(f"Step {record['step']}: {record['action']} — {record['reason']}")