Handle VAD (Voice Activity Detection) events.

Create the positional and keyword arguments to call a function tool from the raw function output from the LLM. Argument-validation failures (

Mark a connection as available for reuse. If connection has been reset, it will not be added to the pool. Args: conn: Th

Open the input gate and arm the no-speech timer. Call once we expect audible speech to begin (e.g. after sip answer for outbound call

Updates the agent's available function tools. If the agent is running in realtime mode, this method also updates the tools f

Verify this event is a function call with matching details. Args: name (str, optional): Expected function name.

Verify this event is a function call output with matching details. Args: output (str, optional): Expected output text.

Assert that there are no further events. Raises: AssertionError: If unexpected events remain. Example:

Helper to create STT with required credentials.

Adds an AgentTask to the TaskGroup. Args: task_factory (Callable): A callable that returns a task instance id (str):

Get a connection from the pool and automatically return it when done. Yields: An active connection object

Switch the tail sink at the bottom of the chain, keeping wrappers attached. Walks the chain looking for a :class:`_AudioSinkProxy` and swaps

Flatten the tool context to a list of tools.

Evaluate whether the message fulfills the given intent. Args: llm_v (llm.LLM): LLM instance for judgment. in

Add a value to the accumulator

Updates the agent's chat context. If the agent is running in realtime mode, this method also updates the chat context for th

Handle transcription result messages.

Update STT configuration options.

Construct a stream wired to a scripted transport. The cloud model starts with empty thresholds (its defaults arrive via ``SessionCreated`` —

Open the WebSocket and start the send/recv/keepalive loops.

Bind a process-local aiohttp.ClientSession to the current asyncio context. Use this when running plugins outside a job worker (e.g. tests, script

A clock time as natural speech, e.g. '7 PM', '6:30 PM'.

ChatContext stub that survives the `.copy()` + `.add_message` + `.items[-N:]` calls inside `_run_eou_detection`.

Remove a specific connection from the pool. Marks the connection to be closed during the next drain cycle. Args: conn: T

Return the interval for the given number of retries. The first retry is immediate, and then uses specified retry_interval

Mark the session as failed. Args: reason: Optional reason for the failure (stored separately from the tag).

Interrupt the current speech generation and any queued speeches. Returns: An asyncio.Future that completes when the interruption

Remove a tag from the session. Args: tag: The tag string to remove.

Switch audio and video streams to specified participant

The conversation without tool mechanics, for handing to a sub-task. Tool calls in the history are scoped to the agent that made them. A sub-t