from agno.workflow import Parallel, Step, Workflow
investment_workflow = Workflow(
id="investment-workflow",
name="Investment Review Pipeline",
steps=[
Step(name="Market Assessment", agent=market_analyst),
Parallel(
Step(name="Fundamental Analysis", agent=financial_analyst),
Step(name="Technical Analysis", agent=technical_analyst),
name="Deep Dive",
),
Step(name="Risk Assessment", agent=risk_officer),
Step(name="Investment Memo", agent=memo_writer),
Step(name="Committee Decision", agent=committee_chair),
],
)
result = investment_workflow.run("Run a full investment review on NVDA")
# result.content is the Committee Decision; result.step_results holds each
# step in order (the Deep Dive is one nested list). Same shape every run.