Sequential Workflows

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)