Run the graph with a single input and config. Args: input: The input data for the graph. It can be a dictionary or any other type

Adds a new node to the state graph. Will take the name of the function/runnable as the node name. Args: node (RunnableLik

Compiles the state graph into a `CompiledGraph` object. The compiled graph implements the `Runnable` interface and can be invoked, st

Adds a directed edge from the start node to the end node. If the graph transitions to the start_key node, it will always transition to the en

Specifies the first node to be called in the graph. Equivalent to calling `add_edge(START, key)`. Parameters: key (str):

Asynchronously invoke the graph on a single input. Args: input: The input data for the computation. It can be a dictionary or any

Add a conditional edge from the starting node to any number of destination nodes. Args: source (str): The starting node. This con

Marks a node as a finish point of the graph. If the graph reaches this node, it will cease execution. Parameters: key (s

* Block until a run is done. * * @param threadId The ID of the thread. * @param runId The ID of the run. * @returns

Writes to channels the result of the lambda, or None to skip writing.

Stream graph steps for a single input. Args: input: The input to the graph. config: The configuration to use for the

Send a POST request.

Stream graph steps for a single input. Args: input: The input to the graph. config: The configuration to use for the

Retrieve a single item. Args: namespace: Hierarchical path for the item. key: Unique identifier within the namespace.

Returns a drawable representation of the computation graph.

Get the current state of the graph.

Create a new BasePostgresStore instance from a connection string. Args: conn_string (str): The Postgres connection info string.

Send a GET request.

Get a cursor for the SQLite database. This method returns a cursor for the SQLite database. It is used internally by the SqliteSaver

Get the current state of the graph.

Create a human message with an any id field.

Update the state of the graph with the given values, as if they came from node `as_node`. If `as_node` is not provided, it will be set to the

Merge multiple configs into one. Args: *configs (Optional[RunnableConfig]): The configs to merge. Returns: RunnableConfig: T

Remove and return an item from the queue. If optional args 'block' is true and 'timeout' is None (the default), block if necessary un

Sets a conditional entry point in the graph. Args: path (Union[Callable, Runnable]): The callable that determines the next

Creates a graph that works with a chat model that utilizes tool calling. Args: model: The `LangChain` chat model that supports tool calli

* List all runs for a thread. * * @param threadId The ID of the thread. * @param options Filtering and pagination options. * @returns List

Merges two lists of messages, updating existing messages by ID. By default, this ensures the state is "append-only", unless the new message h

Asynchronous version of list. This method is an asynchronous wrapper around list that runs the synchronous method in a separate threa

* Cancel a run. * * @param threadId The ID of the thread. * @param runId The ID of the run. * @param wait Whether to block when canceling

Send a DELETE request.

Ensure that a config is a dict with all keys present. Args: config (Optional[RunnableConfig], optional): The config to ensure.

* Get a run by ID. * * @param threadId The ID of the thread. * @param runId The ID of the run. * @returns The run.

Get the history of the state of the graph.

Asynchronously retrieve a single item. Args: namespace: Hierarchical path for the item. key: Unique identifier within

Get the history of the state of the graph.

Patch a config with new values. Args: config (Optional[RunnableConfig]): The config to patch. callbacks (Optional[BaseCallbackMan

Create a tool message with an any id field.

Create a checkpoint for the given channels.

Get checkpoint ID in a backwards-compatible manner (fallback on thread_ts).

List and filter namespaces in the store. Used to explore the organization of data, find specific collections, or navigate the namespa

Store or update an item. Args: namespace: Hierarchical path for the item. key: Unique identifier within the namespace

Create ai message with an any id field.

Coerce a runnable-like object into a Runnable. Args: thing: A runnable-like object. Returns: A Runnable.

Block until the semaphore can be acquired, but don't acquire it.

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

Execute multiple operations asynchronously in a single batch. Args: ops: An iterable of operations to execute. Returns:

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

Send a PATCH request.

Apply writes from a set of tasks (usually the tasks from a Pregel step) to the checkpoint and channels, and return managed values writes to be app

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

Execute multiple operations synchronously in a single batch. Args: ops: An iterable of operations to execute. Returns:

* Copy an existing thread * @param threadId ID of the thread to be copied * @returns Newly copied thread