Save a checkpoint to the database. This method saves a checkpoint to the Postgres database. The checkpoint is associated with the pro

Put writes for a task, to be read by the next tick.

Manage channels for the lifetime of a Pregel invocation (multiple steps).

Convert namespace tuple to text string.

Convert a row from the database into an Item.

Asynchronously delete an item. Args: namespace: Hierarchical path for the item. key: Unique identifier within the nam

Delete an item. Args: namespace: Hierarchical path for the item. key: Unique identifier within the namespace.

Get an async callback manager for a config. Args: config (RunnableConfig): The config. Returns: AsyncCallbackManager: The as

Get a callback manager for a config. Args: config (RunnableConfig): The config. Returns: CallbackManager: The callback manag

Set up the checkpoint database asynchronously. This method creates the necessary tables in the SQLite database if they don't already

Stream results using SSE.

Execute a single iteration of the Pregel loop. Returns True if more iterations are needed.

* Create a run and wait for it to complete. * * @param threadId The ID of the thread. * @param assistantId Assistant ID to use for this run.

Return the exception from a future, without raising CancelledError.

List checkpoints from the database asynchronously. This method retrieves a list of checkpoint tuples from the Postgres database based

Create a pydantic model with the given field definitions. Args: model_name: The name of the model. field_definitions: The field d

Create a new SqliteSaver instance from a connection string. Args: conn_string (str): The SQLite connection string. Yield

Fetch a checkpoint using the given configuration. Args: config (RunnableConfig): Configuration specifying which checkpoint to ret

Get subset of current_versions that are newer than previous_versions.

Get the state of a thread. Args: thread_id: The ID of the thread to get the state of. checkpoint: The checkpoint to g

Put the item on the queue. The optional 'block' and 'timeout' arguments are ignored, as this method never blocks. They are provided

Send a PUT request.

Search for items within a namespace prefix. Args: namespace_prefix: Hierarchical path prefix to search within. filter

Return WHERE clause predicates for (a)search() given metadata filter and `before` config. This method returns a tuple of a string and a tuple

Apply writes / subgraph states to tasks to be returned in a StateSnapshot.

Create ai message with an any id field.

Create ai message with an any id field.

Create a human message with an any id field.

Check if a type is Optional.

Return WHERE clause predicates for (a)search() given metadata filter. This method returns a tuple of a string and a tuple of values. The string

Cancel remaining tasks if any failed, re-raise exception if panic is True.