Step-Based Workflows

from agno.workflow import Step, StepInput, StepOutput, Workflow


def research(step_input: StepInput) -> StepOutput:
    return StepOutput(content=f"Research for {step_input.input}")


def analyze(step_input: StepInput) -> StepOutput:
    return StepOutput(content=f"Analysis:\n{step_input.previous_step_content}")


def write(step_input: StepInput) -> StepOutput:
    return StepOutput(content=f"Draft:\n{step_input.previous_step_content}")

workflow = Workflow(
    name="Content Creation Pipeline",
    steps=[
        Step(name="Research Phase", executor=research),
        Step(name="Analysis Phase", executor=analyze),
        Step(name="Writing Phase", executor=write),
    ],
)

workflow.print_response(
    "AI trends in 2026",
    markdown=True,
)