Update bank name and/or mission.

Handle cleanup of observations when source memories are deleted. For each observation referencing any of the deleted fact IDs:

Get fully-qualified table name with optional schema prefix.

Get fully-qualified table name with schema prefix.

Get the default model for a given provider.

Return the enabled tool set for the current bank, or None if unrestricted.

Load bank config overrides from banks.config JSONB column. Args: bank_id: Bank identifier Returns:

Normalize tool name from various LLM output formats. Some LLMs output tool names in non-standard formats: - 'functions.done' (OpenAI-style pr

Parse ISO datetime string.

Parse ISO datetime string.

Proxy requests to MemoMind API.

Proxy /vault/* requests to NoteDiscovery backend.

Raise an appropriate error including the response body on HTTP errors. Raises UnsupportedFileTypeError for 4xx responses (file rejected by t

Convert a database row to a directive dict.

Convert a database row to a mental model dict.

Generic helper to submit an async operation. Args: bank_id: Bank identifier operation_type: Operation type for the as

Validate mental model inputs, returning an error message or None if valid.

Record results from a single retrieval method. Args: method_name: Name of the retrieval method results: List

Build the final prompt when forcing a text response (no tools).

Build a set of valid 'key:value' label strings (lowercase) for fast lookup. Accepts either EntityLabelsConfig or raw list/None for backwards

Create and configure the FastAPI application. Args: memory: MemoryEngine instance (already initialized with required parameters).

Create and configure the Hindsight MCP server. Args: memory: MemoryEngine instance (required) multi_bank: If True, expose al

Create a parent span for a Hindsight operation (retain, reflect, consolidation, etc.). This creates the span hierarchy: - hindsight.{ope

Ensure the PostgreSQL server is running, starting it if needed.

Return True if entity text belongs to any configured label group. For enum groups: checks the pre-built lookup set. For text groups: che

Register a parser. Args: parser: FileParser instance

Release a connection back to the pool.

Rank documents by relevance to a query. Returns a list of dicts with keys: document, relevance_score, index. Sorted by desce

Resolve a database URL, handling pg0:// embedded database URLs. If the URL is a pg0:// URL, starts the embedded PostgreSQL and returns t

Stop the PostgreSQL server.

Check if this provider supports batch API operations.

Export trace as dictionary.

Verify that the LLM provider is configured correctly by making a simple test call. Raises: RuntimeError: If the connecti

Return a configured wrapper for a specific bank operation. The wrapper applies per-bank overrides (e.g. Gemini safety settings)

Return False if the operation row no longer exists (e.g. bank was deleted via CASCADE). Long-running operations should call this at natural c

Extract directive rules as a list of strings.

Fetch public signing keys from the Supabase JWKS endpoint.

Find the .md file path for a given document_id (conversation id). The index.json stores entries like: {"id": "676c0892-...", "filePath": "c

Get list of schemas to poll. Returns [None] for default schema (no prefix).

Get current tenant (schema) from context for metrics labeling.

Send a JSON error response.

Check if this is a child operation and update parent status if all siblings are done. Must be called within an active transaction that has al

Make an HTTP request with automatic retries on transient errors.

Send an error response.

Serialize an object for span recording, handling Pydantic models.

Return a unique key for the current asyncio task (or 0 for non-task context).

Truncate content if too large for span.

Build a SQL WHERE clause for filtering by tags. Supports four matching modes: - "any" (default): OR matching, includes untagged memories

Make an LLM API call with retry logic. Args: messages: List of message dicts with 'role' and 'content'. resp

Cancel a pending async operation.

Configure Python logging based on the log level and format. When log_format is "json", outputs structured JSON logs with a severity f

Create per-(bank, fact_type) partial HNSW indexes for a newly created bank. Called immediately after the bank row is first inserted. Safe on empt

Delete a document and all its associated memory units and links. Args: document_id: Document ID to delete ba

Convert trait value (1-5) to descriptive text.

Flush all log lines to the logger.

Get bank profile (name, disposition + mission). Auto-creates bank with default values if not exists. Args: pool: Database connec

Get statistics about memory nodes and links for a bank.

Get set of field names that are configurable per-tenant/bank via API. Configurable fields are manually tagged behavioral settings th

Get the current schema from context (falls back to config default).

Get a single directive by ID. Args: bank_id: Bank identifier directive_id: Directive UUID request_context

Retrieve document metadata and statistics. Args: document_id: Document ID to retrieve bank_id: bank ID that

Get a single memory unit by ID. Args: bank_id: Bank ID memory_id: Memory unit ID request_context

Get the status of a specific async operation. For parent operations, the status is automatically updated in the database when all children co

Initialize the embedding model asynchronously. This should be called during startup to load/connect to the model and avoid c

List all agents in the system. Args: request_context: Request context for authentication. Returns:

List documents with optional search and pagination. Args: bank_id: bank ID (required) search_query: Search i

List memory units for table view with optional full-text search. Args: bank_id: Filter by bank ID fact_type:

List async operations for a bank with optional filtering and pagination. Args: bank_id: Bank identifier status: Optio

List all unique tags for a bank with usage counts. Use this to discover available tags or expand wildcard patterns. Supports

List all tenants that should be processed by workers. This method is used by the worker to discover all tenants that need ta

Normalize all keys in a config dict to Python field names. Allows users to provide config overrides in either format: - Python field for

Called after a recall operation completes (success or failure). Override this method to implement post-operation logic such as:

Parse an ISO format timestamp string. Args: timestamp: ISO format timestamp (e.g., '2024-01-15T10:30:00Z') Returns: Parsed d

Context manager to record operation duration and status. Usage: with metrics.record_operation("recall", bank_id="user123

Store multiple content items as memory units in ONE batch operation. This is MUCH more efficient than calling retain_async multiple

Retrieve file by storage key. Args: key: Storage key Returns: File data as bytes Raises:

Execute an async function with exponential backoff retry. Args: func: Async function to execute max_retries: Maximum number

Set the extension context. Called by the extension loader after instantiation. Extensions should not call this directly.

Shutdown the backend gracefully.

Submit a batch retain operation to run asynchronously. For large batches (exceeding retain_batch_chars threshold), automatically splits

Update bank configuration overrides (with permission checking). Args: bank_id: Bank identifier updates: Dict

Update a directive. Args: bank_id: Bank identifier directive_id: Directive UUID name: New name (optional)

Context manager entry.

Context manager exit.

Add time offsets to preserve fact ordering across all contents. This allows retrieval to distinguish between facts from different documents/

Add time offsets to preserve fact ordering across all contents. This allows retrieval to distinguish between facts from different documents/

Compute the observation fields inherited from a set of source memories. Temporal aggregation rules: - ``event_date`` — earliest across sou

Compute the observation fields inherited from a set of source memories. Temporal aggregation rules: - ``event_date`` — earliest across sou

Make an async HTTP request with automatic retries on transient errors and semaphore for backpressure.

Build extraction prompt and response schema based on config. When a taxonomy is configured, dynamically builds a Pydantic model with a t

Build extraction prompt and response schema based on config. When a taxonomy is configured, dynamically builds a Pydantic model with a t

Build a transactional outbox callback for retain.completed webhook events. Returns a coroutine function that queues one webhook delivery row

Build user message for fact extraction.

Build user message for fact extraction.

Background task that exits the process after idle timeout.

Cleanup client resources (idempotent). Args: stop_daemon_on_close: If True, stops the daemon. Otherwise, daemon continue