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,
)