Library with a SQLite implementation of GigaGraph checkpoint saver.
Project description
LangGraph SQLite Checkpoint
Implementation of LangGraph CheckpointSaver that uses SQLite DB (both sync and async, via aiosqlite
)
Usage
from langgraph.checkpoint.sqlite import SqliteSaver
checkpointer = SqliteSaver.from_conn_string(":memory:")
checkpoint = {
"v": 1,
"ts": "2024-07-31T20:14:19.804150+00:00",
"id": "1ef4f797-8335-6428-8001-8a1503f9b875",
"channel_values": {
"my_key": "meow",
"node": "node"
},
"channel_versions": {
"__start__": 2,
"my_key": 3,
"start:node": 3,
"node": 3
},
"versions_seen": {
"__input__": {},
"__start__": {
"__start__": 1
},
"node": {
"start:node": 2
}
},
"pending_sends": [],
"current_tasks": {}
}
# store checkpoint
checkpointer.put(thread_config, checkpoint, {})
# load checkpoint
checkpointer.get(thread_config)
# list checkpoints
list(checkpointer.list(thread_config))
Async
from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
checkpointer = AsyncSqliteSaver.from_conn_string(":memory:")
checkpoint = {
"v": 1,
"ts": "2024-07-31T20:14:19.804150+00:00",
"id": "1ef4f797-8335-6428-8001-8a1503f9b875",
"channel_values": {
"my_key": "meow",
"node": "node"
},
"channel_versions": {
"__start__": 2,
"my_key": 3,
"start:node": 3,
"node": 3
},
"versions_seen": {
"__input__": {},
"__start__": {
"__start__": 1
},
"node": {
"start:node": 2
}
},
"pending_sends": [],
"current_tasks": {}
}
# store checkpoint
await checkpointer.aput(thread_config, checkpoint, {})
# load checkpoint
await checkpointer.aget(thread_config)
# list checkpoints
[c async for c in checkpointer.alist(thread_config)]
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Close
Hashes for gigagraph_checkpoint_sqlite-1.0.0.tar.gz
Algorithm | Hash digest | |
---|---|---|
SHA256 | 928e5382cee0e036c7737603a6e37a1985bb5f0a87fa6f3672caa53d06755adc |
|
MD5 | 262bd53fa410394a15ebb59aeccadf72 |
|
BLAKE2b-256 | a9e759f6a2469b5bad37deef65b94829e8984d52440c526614c09f4c1ee0020a |
Close
Hashes for gigagraph_checkpoint_sqlite-1.0.0-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | e800ded8e39df71469883cc922d0fa1e07c6e9db1659f00a3e9463fe8f91196d |
|
MD5 | fb93c1bceb7a6cf5d8909329ec924b8f |
|
BLAKE2b-256 | 513b2aa9f54a8e03205a7fea03cf545a879ad2d94d3c189d5c2b45c3f63dafdc |