Timeout

from agno.workflow import Workflow
from agno.workflow.step import Step
from agno.workflow.types import OnTimeout
from agno.db.sqlite import SqliteDb

workflow = Workflow(
    name="timeout_workflow",
    db=SqliteDb(db_file="workflow.db"),
    steps=[
        Step(
            name="draft_email",
            agent=draft_agent,
            requires_output_review=True,
            output_review_message="Review the draft (auto-approves in 5 minutes)",
            hitl_timeout=300,
            on_timeout=OnTimeout.approve,
        ),
        Step(name="send_email", agent=send_agent),
    ],
)

run_output = workflow.run("Draft an email about the team lunch")

if run_output.is_paused:
    for req in run_output.steps_requiring_output_review:
        print(f"Draft: {req.step_output.content}")
        print(f"Timeout at: {req.timeout_at}")
        print(f"On timeout: {req.on_timeout}")

    # If called after timeout expires, auto-resolves based on on_timeout
    run_output = workflow.continue_run(run_output)

Step(
    name="generate_report",
    agent=report_agent,
    requires_output_review=True,
    output_review_message="Review the report",
    hitl_timeout=600,           # 10 minutes
    on_timeout=OnTimeout.approve,  # Auto-approve after 10 minutes
)

Step(
    name="deploy",
    agent=deploy_agent,
    requires_confirmation=True,
    confirmation_message="Deploy to production?",
    hitl_timeout=120,            # 2 minutes
    on_timeout=OnTimeout.cancel,  # Cancel if no response
)