User Input Required Stream Async

import asyncio
from typing import List

from agno.agent import Agent
from agno.db.sqlite import SqliteDb
from agno.models.openai import OpenAIResponses
from agno.tools import tool
from agno.tools.function import UserInputField


# You can either specify the user_input_fields leave empty for all fields to be provided by the user
@tool(requires_user_input=True, user_input_fields=["to_address"])
def send_email(subject: str, body: str, to_address: str) -> str:
    """
    Send an email.

    Args:
        subject (str): The subject of the email.
        body (str): The body of the email.
        to_address (str): The address to send the email to.
    """
    return f"Sent email to {to_address} with subject {subject} and body {body}"


agent = Agent(
    model=OpenAIResponses(id="gpt-5.2"),
    tools=[send_email],
    markdown=True,
    db=SqliteDb(session_table="test_session", db_file="tmp/example.db"),
)


async def main():
    async for run_event in agent.arun(
        "Send an email with the subject 'Hello' and the body 'Hello, world!'",
        stream=True,
    ):
        if run_event.is_paused:  # Or agent.run_response.is_paused
            for requirement in run_event.active_requirements:
                if requirement.needs_user_input:
                    input_schema: List[UserInputField] = requirement.user_input_schema  # type: ignore

                    for field in input_schema:
                        # Get user input for each field in the schema
                        field_type = field.field_type
                        field_description = field.description

                        # Display field information to the user
                        print(f"\nField: {field.name}")
                        print(f"Description: {field_description}")
                        print(f"Type: {field_type}")

                        # Get user input
                        if field.value is None:
                            user_value = input(f"Please enter a value for {field.name}: ")
                        else:
                            print(f"Value: {field.value}")
                            user_value = field.value

                        # Update the field value
                        field.value = user_value

            async for resp in agent.acontinue_run(  # type: ignore
                run_id=run_event.run_id,
                updated_tools=run_event.tools,
                stream=True,
            ):
                print(resp.content, end="")

    # Or for simple debug flow
    # agent.aprint_response("Send an email with the subject 'Hello' and the body 'Hello, world!'")


if __name__ == "__main__":
    asyncio.run(main())