CosmosDBSaver(
self,
container: Any,
*,
serde: SerializerProtocol | None = None
)| Name | Type | Description |
|---|---|---|
container* | Any | An already-created async |
serde | SerializerProtocol | None | Default: NoneOptional custom serializer. |
| Name | Type |
|---|---|
| container | Any |
| serde | SerializerProtocol | None |
Asynchronous CosmosDB implementation of BaseCheckpointSaver.
Uses the native azure.cosmos.aio async client for non-blocking I/O.
Sync methods (get_tuple, list, put, put_writes)
are provided for compatibility and delegate to the async implementations
via asyncio.run_coroutine_threadsafe.
Use from_conn_info to create an instance:
Example:
async with CosmosDBSaver.from_conn_info( ... endpoint="https://your-account.documents.azure.com:443/", ... key="your_key", ... database_name="langgraph_db", ... container_name="checkpoints", ... ) as saver: ... config = {"configurable": {"thread_id": "thread-1"}} ... checkpoint_tuple = await saver.aget_tuple(config)