Wait for all dispatched tasks to complete. Args: timeout: Maximum time to wait in seconds. None means wait forever. Retu

Retrieve a memory by ID. Args: memory_id (str): ID of the memory to retrieve. Returns: dict: Retrie

Get a textual memory from a MemCube. Args: mem_cube_id (str): The identifier of the MemCube to get the memory from.

Get items - completely lock-free.

Retrieve a message from Kafka. Args: timeout: Timeout in seconds (defaults to consumer_timeout_ms from config)

Returns an iterator equivalent to map(fn, iter). Automatically propagates the current thread's context to worker threads.

Execute the task based on its type and yield results with the next task's batch size.

Get keys - completely lock-free.

Get values - completely lock-free.

Pop item by key.

Add information to memory. Args: content: Information to memorize **kwargs: Additional options (images, meta

Run the MemChat. This `run` method can represent the core logic of a MemChat. It could be an iterative chat process.

Get a user by id. :param id: Id. of the user to retrieve. :raises UserNotExists: The user does not exist. :return: A

Execute a query using PGlite bridge (async).

Parse the file at the given path and return its content as a string.

returns the project logger, scoped to a child name if provided Args: name: will define a child logger

Execute a Kuzu query asynchronously with automatic reconnection.

Submit a callable to be executed with the given arguments. Automatically propagates the current thread's context to the worker thread

Create a copy - completely lock-free.

Dump the MemCube to a dictionary. Args: dump_dir (str): The directory to dump the MemCube to. user_id (str, optional):

Encode inputs into embeddings Args: inputs: can be string, list of strings, or BatchEncoding results from tokenizer Retu

Fetch the user or default user.

Get items from the queue. Args: block: Whether to block if no items are available (default: True) timeout: Timeout in

Get a memory by its ID. Args: memory_id (str): The ID of the memory to retrieve. Returns: TextualMemoryItem: T

Resolve detected conflicts between two memory items using LLM fusion. Args: memory_a: The first conflicting memory item.

Insert vectors into a collection. Args: vectors (List[list]): List of vectors to insert. payloads (Optional[

The primary accessor for an ORM record. Args: db_session: the database session to use when retrieving the record ident

The primary accessor for an ORM record (async).

* Helper to invoke a registered handler

Add textual memories to a MemCube. Args: messages (Union[MessageList, str]): The path to a document or a list of message

Update a textual memory in a MemCube by text_memory_id and text_memory_id. Args: mem_cube_id (str): The identifier of th

Generate a response from the model. If past_key_values is provided, use cache-augmented generation. Args: messages (Messa

Set a value in the context.

Delete a raw memory (hard delete, used by cleanup job). Args: memory_id: ID of the memory to delete actor: C

Create a new raw memory record (direct write, no queue). Args: raw_memory: The raw memory data to create act

Create and initialize a Mirix memory agent (async). Use this instead of __init__. Example: memory_agent = await Mirix.cr

Get a configured structlog logger. Args: name: Logger name (default: None, uses __name__) level: Logging level (default: None)

Load memory state from a backup directory. Note: Load/restore functionality is not yet implemented in the client-based SDK.

Get the Mirix logger with configured handlers. Log Level Configuration: - Single log level (MIRIX_LOG_LEVEL) applies to ALL handlers

Get or create the singleton AsyncServer instance.

Fetch a client by ID (with cache - Redis or IPS Cache).

Print verbose logging output. Controlled by context-specific verbose setting (thread-safe).

Ensure user, organization, and client are set. Call after __init__.