Get a row by ID.

Factory for creating ResolvedContext objects for benchmark testing. Returns a factory function that creates ResolvedContext with sensible def

Run an agent with the given initialization payload. This is the main entry point for sandboxed execution. Called after receiving init

Run a git command asynchronously. Args: args: Git command arguments (including 'git' as first argument). env: Environment variabl

Search cases with cursor-based pagination and filtering.

Serialize data to JSON bytes using orjson. Args: data: Any JSON-serializable data Returns: UTF-8 encoded JSON bytes

Factory for creating simple RunActionInput objects for testing. Returns a factory function that creates RunActionInput with sensible defaults

Construct a sanitized environment for the nsjail process.

Get a worker with available capacity. Workers can handle multiple concurrent tasks up to max_concurrent_per_worker. This method finds

Properly quote SQL identifiers to prevent injection and handle special characters. Args: name: The identifier name to quote

Remove stale upstream edge references from actions. The graph layout is stored in action.upstream_edges and workflow trigger coordina

Return the bucket used for staged workflow file blobs.

Factory to create workers configured for agent workflows.

Best-effort auto-title on first prompt via direct PydanticAI call.

Calculate percentile of a list of values.

Create a full activity list with mocked executor and session activities. This mocks run_agent_activity and session activities to avoid database

Create and assign a domain to an organization.

Create a new organization setting.

Import an external workflow definition into the current workspace. Optionally validate the workflow definition before importing. (Default: Fa

Decrypt a Fernet-encrypted value back to a string. Args: encrypted_value: The encrypted bytes key: The decryption key Return

Deserialize JSON bytes to Python object using orjson. Args: content: UTF-8 encoded JSON bytes Returns: Deserialized Python o

Get a presigned S3 URL for downloading an attachment.

Get the field schema (column definitions) for this workspace. Returns a dict mapping field_id -> {type, options (only for SELECT/MULTI_SELECT

Get an MCP integration by ID.

Get a registry version by ID.

Check and cache entitlement access for this service instance.

Perform a HTTP request to a given URL with optional polling.

Check whether a column is internal/system-managed for dynamic schemas.

Check if a value is iterable, optionally excluding string-like and mapping types. Args: value: The value to check for iterability

List rows in a table with cursor-based pagination. Args: table: The table to search in params: Cursor pagination para

List immutable versions for a preset ordered newest first.

Map a single CSV row to table columns with type conversion.

Parse dependency conflicts from package manager error messages. Args: error_message: The error message containing dependency conflic

Register GitHub App credentials for the organization. Args: app_id: GitHub App ID private_key_pem: GitHub App private

Replace all occurrences of old substring with new substring.

Serialize a comment for API responses with tombstone semantics.

Set the agent state in context.

Return an iterator of all expressions in a nested object.

Iterate through the leaves of a nested dictionary. Each iterations returns the location (jsonpath) and the value.

Update a single approval record.

Update an existing comment. Args: comment: The comment to update params: The updated comment parameters Retu

Update a workspace secret.

Validate that a template action is correctly formatted.

Get the platform-specific secrets for the selected model. Args: use_workspace_credentials: If True, use workspace-scoped credenti

Build a single-action DSL used by concurrency tests. The returned DSL keeps the action name and reference stable, while allowing the caller t

Execute an action in a direct subprocess (no sandbox).

Get the full table name for a table.

Helper function to create MinIO client.

Return the current MCP session id.

Resolve the execution timeout based on workspace settings and DSL config. Precedence order: 1. If workspace unlimited timeout enabled

Run alembic upgrade to a specific revision.

Interactive selection using numbered list. Args: prompt: The prompt to display items: List of (display_text, value) tuples R

Send an envelope over the socket.

Accept a workspace invitation. This method validates the invitation, creates org membership if needed, creates the workspace membersh

Add a user to a group.

Read a numeric env var with default and optional clamped bounds.

Convert DB Actions into ActionStatements using upstream_edges. This function uses Action.upstream_edges directly as the source of truth for d

Build the shared correlation ID for workflows in one agent session.

Build a safe lambda function from a string expression.

Convert supported inputs into a timezone-aware UTC datetime.

Configure lifecycle rules for a bucket to expire objects after N days. Args: bucket: Bucket name expiration_days: Number of days