Abort the current idle dwell — the next iteration restarts from wait_for_idle. Called by ``ctx.update()`` to signal that the tool just took t

Retrieve the VoiceAgent associated with the current agent. Raises: RuntimeError: If the agent is not running

Update the instruction message in the chat context or insert a new one if missing. This function looks for an existing instruction message i

Update the turn detector and turn detector stream if possible. When *stream* is provided it is adopted as-is (handoff reuse) instead of

Calculate hyphens for text.

Check if the user turn exceeds configured limits. Called when a final transcript event is received.

Clean up context state

Clean up processor session resources (required by FrameProcessor interface). Note: This method is called during track transitions (when strea

Convert a Pydantic model to a different type with the same field structure.

Create an AudioRecognition instance with mocked dependencies.

Instantiate _ResponseGeneration and emit the GenerationCreated event. Can be called multiple times - will reuse existing generation but ensur

Call the real _detach_reusable_resources, return turn_detector_stream.

Implementation of stack trace dumping (callable directly or from signal handler).

Run LLM evaluation using function calling for reliable verdict extraction.

Fail all registered streams and mark the connection non-current.

API expects an ISO 639-1 language code (without region)

Get base URL and streaming URL based on model type. Args: model: The Sarvam model name Returns: Tuple of (base_url, streamin

Handle error messages from the API.

Check if model is Gemini 3 series

Build a TurnHandlingOptions from deprecated keyword arguments.

Retrieve information about the module without importing it. Cache to avoid redundant filesystem reads.

Return the observability endpoint, or None if observability is unavailable.