Get a Redis key value.

Stream a message to a Redis stream.

Emit an error marker.

Execute a Python script inside the nsjail sandbox. Args: job_dir: Directory containing the job files (script.py, inputs.json, wra

Record a validation result.

Set a secret in the current context.

Decode payloads, decompressing those that were compressed.

Create a stream ID for an inherited scatter item. Args: scope: The scope name for the stream. index: The index or ski

Make a GET request.

Make a POST request.

Commit and push objects to a repository/branch. Args: objects: Domain models to serialize and write. url: Repository

Set a Redis key with an optional TTL.

Create an AuditService instance with a database session. Override BaseService.with_session to accept optional role parameter. Accepts

Encode payloads, compressing those that exceed the threshold.

Factory fixture to create workers with proper ThreadPoolExecutor cleanup.

Convert the UUID to a shortened, prefixed string representation. Returns: ShortIDType: The shortened ID string with prefix

Delete a Redis key.

Type guard that narrows T | Unset to T. Use this to get proper type narrowing when checking if a value was provided. Uses both isinstance()

Check if a Redis key exists.

Make a PATCH request.

Retrieve a registered udf.

Execute a workflow by ID or alias. Args: workflow_id: Workflow UUID (short or full format). workflow_alias: Workflow

Update a user with user privileges.

Cast a FastMCP-decorated tool back to a callable for test invocation. ``@mcp.tool()`` is typed as returning ``FunctionTool`` (not callable),

Serialize to JSON string.

Get the current registry context. Returns: The current RegistryContext. Raises: RuntimeError: If no context is set.

Resolve workspace UUID + role from current token.

Create a new case.

Factory fixture to create executor workers with TestBackend. This worker listens on the shared-action-queue and handles execute_action_activity.

Create a service instance with a database session. Args: session: Optional existing session. If provided, caller is responsible

Print an error message to stderr.

Create a StreamEvent with the given raw event dict.

Normalize tool output into plain Python data for assertions.

Initialize and connect to the service.

Get the current agent state from context.

Validate the input arguments for a Bound registry action. Checks: 1. The Bound registry action must be called with keyword arguments

Get a specific key's value from a workspace variable, or return a default. Args: name: The variable name (e.g., "api_config").

Evaluate the expression and return the result.

Create a new comment on a case. Args: case: The case to comment on params: The comment parameters Returns:

Get a case with its associated custom fields. Args: case_id: UUID of the case to retrieve track_view: Whether to reco

Factory for FastAPI dependency that enforces role-based access control. This function creates a dependency for authenticating and authorizin

Store or update a user's integration.

Create a new MCP integration.

Create a mock Temporal history event.

Get a context manager for an async SQLAlchemy database session with RLS context.

Process the request and apply rate limiting. Args: request: The FastAPI request call_next: The next middlewa

Number of iterations in this batch.

Convert a harness-native stream event to unified format.

Create an org admin role for testing (not a platform superuser).