Emit the completion event for a successful checkpoint write.

Emit the failure event for a checkpoint write.

Emit a compact transcript event for conversational trace views.

Emit the conversational routing decision for the current turn.

Emit failure event and return formatted error message.

Emit ``FlowFailedEvent`` and close out the trace batch for a failed run. Mirrors the terminal block of the success path: drain pending event

Emit a kickoff error event and re-raise.

Emit usage for always-on skills injected into this task's prompt. Metadata-only skills emit from ``LoadSkillTool`` if the model selects

Emit a terminal turn event and wait for its own handlers.

Emit an event with dependency-aware handler execution. Handlers are grouped into execution levels based on their dependencies. Within

Ensure async client is initialized and return it.

Lazily initialize the thread pool executor and event loop. Called on first emit() to avoid startup overhead when events are never used.

Convert embedding to list[float] format if needed. Args: embedding: Embedding vector as list or numpy array. Returns: Embedd

Make sure the parent directory of `path` exists. Daytona's upload returns 400 if the parent directory is missing. We best-effort mkdi

Lazily create the PlannerObserver (avoids circular imports).

Lazily create the StepExecutor (avoids circular imports).

Return the table, creating it lazily if needed. Args: vector_dim: Dimension hint (e.g. from the first embedding).

Return a compact description of environment variables for prompts.

Execute delegation to an agent with case-insensitive and whitespace-tolerant matching. Args: agent_name: Name/role of th

Execute the agent synchronously and build the output object.

Run the core execution logic of the task.

Internal implementation for task execution with optional extensions.

Execute a method and emit events. Returns: A tuple of (result, finished_event_id) where finished_event_id is the even

Executes a single listener method with proper event handling. This internal method manages the execution of an individual listener, i

Wrap execute_task with A2A delegation logic. Args: self: The agent instance a2a_agents: Dictionary of A2A agent configurations

Execute text-parsed tool calls with tool usage events.

Execute tools and collect results in Anthropic format. Args: tool_uses: List of tool use blocks from Claude's response (regular o

Return the uppercased first keyword of *sql_query*.

Extract raw finish_reason and response_id from a Gemini ``GenerateContentResponse``. ``finish_reason`` is the protobuf enum's ``.name`

Extract function calls from Responses API output.

Extract the main (outer) query that follows all CTE definitions. For ``WITH cte AS (SELECT 1) DELETE FROM users``, returns ``DELETE FROM users``.

Extract schema properties and required fields from action schema.

Extract search parameters from kwargs. Args: kwargs: Keyword arguments containing search parameters. Returns: ExtractedSearc

Extract clean server name from URL for tool prefixing.

Extract tool definitions from toolUse blocks in message history. When no tools are passed but messages contain toolUse, we need to re

Extract a GitHub zipball into dest, stripping the top-level directory.

Get content type from filename extension, then content sniffing. The extension lookup runs first so specific types like ``text/csv`` or ``app

Fetch agent cards concurrently for multiple A2A agents. Args: a2a_agents: List of A2A agent configurations Returns: Tuple of

Fetch initial access token using authorization code flow. Args: client: HTTP client for making token request. Raises:

Filter files to those with supported content types. Args: files: All files. supported_types: MIME type prefixes to allow. Re

Finalize completion response with validation and event emission. Args: content: The response content contents: Origin

Apply guardrails, save to memory, and emit completion event. Args: output: The execution output. executor: The agent

Finalize streaming by unregistering handler and setting result. Args: state: The streaming state to finalize. streaming_output: T

Finalize streaming response with usage tracking, function execution, and events. Args: full_response: The complete streamed respo

Finalize streaming response with usage tracking, tool execution, and events. Args: full_response: The complete streamed response

Finalize a streaming response with usage tracking, tool call handling, and events. Args: full_response: The accumulated text resp

Finalize task execution with RPM cleanup, tool processing, and event emission. Args: task: The task that was executed.

Heavy initialization: state creation, events, memory, method registration.

Format a single file block using the appropriate formatter. Args: formatter: Provider formatter. file_input: Original file input.

Describe the completed wait back to the model. Args: waited: The duration actually waited. requested: The duration th

Render a duration with a correctly pluralized unit. Args: value: The duration in seconds. Returns: The duration and its unit

Format text as a provider-specific content block. Args: text: The text content to format. provider: Provider name for provider-sp

Generate a unique S3 key for the file. For FilePath sources with no content provided, computes hash via streaming. Args:

Compute an anonymized user identifier from username and machine ID.

Generate a deterministic UUID based on a seed string. Args: seed: The seed string to use for UUID generation Returns:

Get the API key from environment variables.

Get or create the async S3 client.

Get or create the async Anthropic client.

Gemini uses a single client for both sync and async calls.

Get audio duration in seconds using tinytag if available. Args: content: Raw audio bytes. filename: Optional filename for format

Get client parameters. Args: include_http_client: When True (default) and an interceptor is set, attach a sync ``

Get a connection from the pool or create a new one.

Get a connection from the connection pool. Returns: Connection: A SingleStore database connection Raises: Ex

Get default API key from environment variables.

Request a device code from the provider.

Get default value from a FieldInfo, handling both default and default_factory.

Get the filesystem path if file source is FilePath. Args: file: The file input to check. Returns: Path if source is FilePath

Get file size without reading content if possible. Args: file: The file to get size for. Returns: File size in bytes, or Non

Get formatter for provider. Args: provider_lower: Lowercase provider name. api: API variant (e.g., "responses" for OpenAI Respons

Get Bedrock image format from content type. Args: content_type: MIME type. Returns: Format string for Bedroc

Get the last user message content from _messages for recall/input.

Get max step iterations from planning config or default to 15.

Get all available memory systems with their configuration. Returns: Dict containing all memory systems with their reset functions

Get the mode mode for a file. Args: file: The file to get mode for. Returns: The file's mode mode, defaultin

Get the appropriate API key based on the model being used.

Return the number of parameters a handler accepts, with caching. Falls back to uncached introspection for unhashable handlers like functools.