from agno.workflow import StepInput, StepOutput, Workflow
def collect_research(step_input: StepInput) -> StepOutput:
topic = str(step_input.input)
return StepOutput(content=f"Research notes for {topic}")
def process_research(step_input: StepInput) -> StepOutput:
research = step_input.previous_step_content or "No research available"
return StepOutput(content=f"Processed data:\n{research}")
def create_review(step_input: StepInput) -> StepOutput:
processed = step_input.previous_step_content or "No processed data available"
return StepOutput(content=f"Final review:\n{processed}")
workflow = Workflow(
name="Sequential Analysis Pipeline",
steps=[
collect_research,
process_research,
create_review,
],
)
workflow.print_response("Analyze the competitive landscape for fintech startups", markdown=True)