Produce "checkpoint" events for stream_mode=debug.

Produce "task_result" events for stream_mode=debug.

Produce "task" events for stream_mode=debug.

Map pending writes (a sequence of tuples (channel, value)) to output chunk.

Cool.

Get a runnable that combines `bound` and `writers`.

Send a PATCH request.

* Patch the metadata of a thread. * * @param threadIdOrConfig Thread ID or config to patch the state of. * @param metadata Metadata to patch

Send a POST request.

Save a checkpoint to the database. This method saves a checkpoint to the SQLite database. The checkpoint is associated with the provi

The implementation of put() merges config["configurable"] (a run's configurable fields) with the metadata field. The state of the chec

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

Save a checkpoint to the in-memory storage. This method saves a checkpoint to the in-memory storage. The checkpoint is associated wit

Store a checkpoint with its configuration and metadata. Args: config (RunnableConfig): Configuration for the checkpoint.

Send a PUT request.

* Store or update an item. * * @param namespace A list of strings representing the namespace path. * @param key The unique identifier for the

Store or update an item. Args: namespace: A list of strings representing the namespace path. key: The unique identifi

Store or update an item. Args: namespace: A list of strings representing the namespace path. key: The unique identifi

Store intermediate writes linked to a checkpoint. This method saves intermediate writes associated with a checkpoint to the SQLite database.

Store intermediate writes linked to a checkpoint. This method saves intermediate writes associated with a checkpoint to the Postgres database

Store intermediate writes linked to a checkpoint. This method saves intermediate writes associated with a checkpoint to the database.

Save a list of writes to the in-memory storage. This method saves a list of writes to the in-memory storage. The writes are associated

Store intermediate writes linked to a checkpoint. Args: config (RunnableConfig): Configuration of the related checkpoint.

Return the approximate size of the queue (not reliable!).

* Resets the parser state. This is required when you have a new stream of messages - * for instance in the case of a client being disconnected and