Periodically close idle connections that have been unused for a while.

Periodically clean up orphaned contexts stuck in CLOSING state.

Standard dynamic-programming LCS to get the common subsequence of IDs (in order) that appear in both old_ids and new_ids.

Connect to the LiveKit Adaptive Interruption WebSocket.

Open a WebSocket and send the ``StreamingWhisperInput`` metadata message. The metadata schema must match the Baseten server's ``StreamingWhis

Establish WebSocket connection to ElevenLabs Scribe v2 API

Open a WebSocket connection to the Soniox Speech-to-Text API and send the initial configuration.

Transcribe the audio stream and run through STT.

Create an AudioRecognition instance with mocked dependencies.

Create a new Krisp session with the correct sample rate. Args: sample_rate: The sample rate of the audio frames in Hz.

Create a SpeechEvent from Gladia's transcript data.

Create a WAV header for streaming with maximum possible size.

Get the current connection, creating one if needed. Returns: Tuple of (connection, acquire_time, connection_reused)

Wait for in-flight tool results to be delivered, then recycle.

Shutdown the session after the tool reply is played out

Unregister pytest-asyncio-concurrent so it doesn't fight xdist. Its runtestloop wrapper and collection regrouping assume a single in-process

Find every pydantic model field whose `default_factory` is a real clock, grouped by model. Self-maintaining: any new event/chat-context model wit

Import the user's entrypoint and return the AgentServer it defines. Reuses the discovery in cli.discover (prefers an app, server, or agent global

Wait for this tool's pending deferred reply to finish delivery, if any.

Transcription example without streaming (single string)

Transcription example using a tts stream (we split text into chunks just for the example)

Surface a concurrent group's captured fd output -- but only if a member failed. The output can't be attributed to a single member (they shared th

One concurrent group per module: module-level tests plus every class in the file. The plugin pins a group to the parent of its first member a