fix(pregel): skip scheduler writes on interrupt

.github/workflows/_integration_test.yml

@@ -37,7 +37,7 @@ jobs:
       run:
         working-directory: libs/cli
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - name: Get changed files
         id: changed-files
         if: github.event_name != 'workflow_dispatch'
@@ -126,8 +126,8 @@ jobs:
             exit 1
           fi
           LANGCHAIN_ANTHROPIC_VERSION=$(docker run --rm --entrypoint "" langgraph-test-h python -c "import sys; from importlib.metadata import version; v = version('langchain-anthropic'); print(v);")
-          if [ "$LANGCHAIN_ANTHROPIC_VERSION" != "1.4.6" ]; then
-            echo "LANGCHAIN_ANTHROPIC_VERSION != 1.4.6; $LANGCHAIN_ANTHROPIC_VERSION"
+          if [ "$LANGCHAIN_ANTHROPIC_VERSION" != "1.0.0a5" ]; then
+            echo "LANGCHAIN_ANTHROPIC_VERSION != 1.0.0a5; $LANGCHAIN_ANTHROPIC_VERSION"
             exit 1
           fi
 

.github/workflows/_lint.yml

@@ -31,7 +31,7 @@ jobs:
           - "3.12"
     name: "lint #${{ matrix.python-version }}"
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - name: Get changed files
         id: changed-files
         if: github.event_name != 'workflow_dispatch'

.github/workflows/_sdk_integration_test.yml

@@ -23,7 +23,7 @@ jobs:
     env:
       HAS_LANGSMITH_API_KEY: ${{ secrets.LANGSMITH_API_KEY != '' }}
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       - name: Set up Python
         uses: ./.github/actions/uv_setup
@@ -33,7 +33,7 @@ jobs:
           working-directory: libs/sdk-py
 
       - name: Login to Docker Hub
-        uses: docker/login-action@dbcb813823bdd20940b903addbd779551569679f # v4
+        uses: docker/login-action@650006c6eb7dba73a995cc03b0b2d7f5ca915bee # v4
         if: ${{ !github.event.pull_request.head.repo.fork }}
         with:
           username: ${{ secrets.DOCKERHUB_USERNAME }}

.github/workflows/_test.yml

@@ -25,7 +25,7 @@ jobs:
 
     name: "test #${{ matrix.python-version }}"
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - name: Set up Python ${{ matrix.python-version }}
         uses: ./.github/actions/uv_setup
         with:
@@ -33,7 +33,7 @@ jobs:
           cache-suffix: test-${{ inputs.working-directory }}
           working-directory: ${{ inputs.working-directory }}
       - name: Login to Docker Hub
-        uses: docker/login-action@dbcb813823bdd20940b903addbd779551569679f # v4
+        uses: docker/login-action@650006c6eb7dba73a995cc03b0b2d7f5ca915bee # v4
         if: ${{ !github.event.pull_request.head.repo.fork }}
         with:
           username: ${{ secrets.DOCKERHUB_USERNAME }}

.github/workflows/_test_langgraph.yml

@@ -23,7 +23,7 @@ jobs:
         working-directory: libs/langgraph
     name: "test #${{ matrix.python-version }}"
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - name: Set up Python ${{ matrix.python-version }}
         uses: ./.github/actions/uv_setup
         with:
@@ -31,7 +31,7 @@ jobs:
           cache-suffix: "test-langgraph"
           working-directory: libs/langgraph
       - name: Login to Docker Hub
-        uses: docker/login-action@dbcb813823bdd20940b903addbd779551569679f # v4
+        uses: docker/login-action@650006c6eb7dba73a995cc03b0b2d7f5ca915bee # v4
         if: ${{ !github.event.pull_request.head.repo.fork }}
         with:
           username: ${{ secrets.DOCKERHUB_USERNAME }}

.github/workflows/_test_release.yml

@@ -23,7 +23,7 @@ jobs:
       version: ${{ steps.check-version.outputs.version }}
 
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       - name: Set up Python ${{ env.PYTHON_VERSION }}
         uses: ./.github/actions/uv_setup
@@ -74,7 +74,7 @@ jobs:
       id-token: write
 
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       - uses: actions/download-artifact@3e5f45b2cfb9172054b4087a40e8e0b5a5461e7c # v8.0.1
         with:
@@ -82,7 +82,7 @@ jobs:
           path: ${{ inputs.working-directory }}/dist/
 
       - name: Publish to test PyPI
-        uses: pypa/gh-action-pypi-publish@dc37677b2e1c63e2034f94d8a5b11f265b73ba33 # release/v1
+        uses: pypa/gh-action-pypi-publish@cef221092ed1bacb1cc03d23a2d87d1d172e277b # release/v1
         with:
           packages-dir: ${{ inputs.working-directory }}/dist/
           verbose: true

.github/workflows/baseline.yml

@@ -17,7 +17,7 @@ jobs:
       run:
         working-directory: libs/langgraph
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - run: SHA=$(git rev-parse HEAD) && echo "SHA=$SHA" >> $GITHUB_ENV
       - name: Set up Python 3.11
         uses: ./.github/actions/uv_setup
@@ -30,7 +30,7 @@ jobs:
       - name: Run benchmarks
         run: OUTPUT=out/benchmark-baseline.json make -s benchmark
       - name: Save outputs
-        uses: actions/cache/save@55cc8345863c7cc4c66a329aec7e433d2d1c52a9 # v6.1.0
+        uses: actions/cache/save@27d5ce7f107fe9357f9df03efb73ab90386fccae # v5.0.5
         with:
           key: ${{ runner.os }}-benchmark-baseline-${{ env.SHA }}
           path: |

.github/workflows/bench.yml

@@ -15,7 +15,7 @@ jobs:
       run:
         working-directory: libs/langgraph
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - id: files
         name: Get changed files
         uses: Ana06/get-changed-files@25f79e676e7ea1868813e21465014798211fad8c # v2.3.0
@@ -30,7 +30,7 @@ jobs:
       - name: Install dependencies
         run: uv sync --group test
       - name: Download baseline
-        uses: actions/cache/restore@55cc8345863c7cc4c66a329aec7e433d2d1c52a9 # v6.1.0
+        uses: actions/cache/restore@27d5ce7f107fe9357f9df03efb73ab90386fccae # v5.0.5
         with:
           key: ${{ runner.os }}-benchmark-baseline
           restore-keys: |

.github/workflows/ci.yml

@@ -30,8 +30,8 @@ jobs:
       deps: ${{ steps.filter.outputs.deps || 'true' }}
       sdk_py: ${{ steps.filter.outputs.sdk_py || 'true' }}
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
-      - uses: dorny/paths-filter@ceb8a2b8f2d89434be7ff52d3de7ec3738c5cc9d # v4
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
+      - uses: dorny/paths-filter@fbd0ab8f3e69293af611ebaee6363fc25e6d187d # v4
         if: github.event_name != 'workflow_dispatch'
         id: filter
         with:
@@ -112,9 +112,9 @@ jobs:
     name: "Check SDK methods matching"
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - name: Set up Python
-        uses: actions/setup-python@5fda3b95a4ea91299a34e894583c3862153e4b97 # v7.0.0
+        uses: actions/setup-python@a309ff8b426b58ec0e2a45f0f869d46889d02405 # v6.2.0
         with:
           python-version: "3.11"
       - name: Run check_sdk_methods script
@@ -130,7 +130,7 @@ jobs:
         python-version:
           - "3.13"
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       - name: Set up Python ${{ matrix.python-version }}
         uses: ./.github/actions/uv_setup
         with:

.github/workflows/deploy-redirects.yml

@@ -26,10 +26,10 @@ jobs:
     runs-on: ubuntu-latest
     steps:
       - name: Checkout
-        uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+        uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       - name: Setup Python
-        uses: actions/setup-python@5fda3b95a4ea91299a34e894583c3862153e4b97 # v7.0.0
+        uses: actions/setup-python@a309ff8b426b58ec0e2a45f0f869d46889d02405 # v6.2.0
         with:
           python-version: '3.11'
 

.github/workflows/release.yml

@@ -25,7 +25,7 @@ jobs:
       tag: ${{ steps.check-version.outputs.tag }}
 
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       - name: Set up Python
         uses: ./.github/actions/uv_setup
@@ -87,7 +87,7 @@ jobs:
     outputs:
       release-body: ${{ steps.generate-release-body.outputs.release-body }}
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
         with:
           repository: langchain-ai/langgraph
           path: langgraph
@@ -158,7 +158,7 @@ jobs:
       - test-pypi-publish
     runs-on: ubuntu-latest
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       # We explicitly *don't* set up caching here. This ensures our tests are
       # maximally sensitive to catching breakage.
@@ -262,7 +262,7 @@ jobs:
         working-directory: ${{ inputs.working-directory }}
 
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       - name: Set up Python
         uses: ./.github/actions/uv_setup
@@ -278,7 +278,7 @@ jobs:
           path: ${{ inputs.working-directory }}/dist/
 
       - name: Publish package distributions to PyPI
-        uses: pypa/gh-action-pypi-publish@dc37677b2e1c63e2034f94d8a5b11f265b73ba33 # release/v1
+        uses: pypa/gh-action-pypi-publish@cef221092ed1bacb1cc03d23a2d87d1d172e277b # release/v1
         with:
           packages-dir: ${{ inputs.working-directory }}/dist/
           verbose: true
@@ -304,7 +304,7 @@ jobs:
         working-directory: ${{ inputs.working-directory }}
 
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
 
       - name: Set up Python
         uses: ./.github/actions/uv_setup

.github/workflows/uv_lock_ugprade.yml

@@ -16,7 +16,7 @@ jobs:
     runs-on: ubuntu-latest
     
     steps:
-      - uses: actions/checkout@3d3c42e5aac5ba805825da76410c181273ba90b1 # v7.0.1
+      - uses: actions/checkout@df4cb1c069e1874edd31b4311f1884172cec0e10 # v6.0.3
       
       - name: Set up uv
         uses: ./.github/actions/uv_setup

.gitignore

@@ -76,12 +76,7 @@ __pypackages__/
 
 # Environments
 .env
-.env.*
 .envrc
-*.crt
-*.key
-*.pem
-credentials.json
 .venv
 .venvs
 env/
@@ -103,7 +98,6 @@ dmypy.json
 
 .vercel
 .turbo
-node_modules/
 .editorconfig
 .scratch
 .worktrees/

AGENTS.md

@@ -2,14 +2,6 @@
 
 This repository is a monorepo. Each library lives in a subdirectory under `libs/`.
 
-<corridor>
-
-## Corridor security analysis
-
-When Corridor's `analyzePlan` tool is available, create a plan and use the tool to analyze it before generating or modifying code. Apply the resulting security guidance before writing code.
-
-</corridor>
-
 When you modify code in any library, run the following commands in that library's directory before creating a pull request:
 
 - `make format` – run code formatters

CLAUDE.md

@@ -2,14 +2,6 @@
 
 This repository is a monorepo. Each library lives in a subdirectory under `libs/`.
 
-<corridor>
-
-## Corridor security analysis
-
-Before generating or modifying code, create a plan and use Corridor's `analyzePlan` tool to analyze it. Apply the resulting security guidance before writing code.
-
-</corridor>
-
 When you modify code in any library, run the following commands in that library's directory before creating a pull request:
 
 - `make format` – run code formatters

libs/checkpoint-conformance/langgraph/checkpoint/conformance/spec/test_delta_channel_history.py

@@ -6,12 +6,9 @@ import traceback
 from collections.abc import Callable
 from uuid import uuid4
 
-from langgraph.checkpoint.base import BaseCheckpointSaver, Checkpoint
-from langgraph.checkpoint.base.id import uuid6
-from langgraph.checkpoint.serde.types import _DeltaSnapshot
+from langgraph.checkpoint.base import BaseCheckpointSaver
 
 from langgraph.checkpoint.conformance.spec._delta_fixtures import build_delta_chain
-from langgraph.checkpoint.conformance.test_utils import generate_metadata
 
 
 async def test_history_returns_writes_oldest_first(
@@ -51,6 +48,8 @@ async def test_history_seed_is_nearest_snapshot(
     result = await saver.aget_delta_channel_history(config=head, channels=["ch"])
     assert "seed" in result["ch"], "Expected seed from snapshot at step 3"
     seed = result["ch"]["seed"]
+    from langgraph.checkpoint.serde.types import _DeltaSnapshot
+
     actual_value = seed.value if isinstance(seed, _DeltaSnapshot) else seed
     assert actual_value == 3, f"Expected seed value 3 (step 3), got {actual_value}"
     writes = result["ch"]["writes"]
@@ -82,6 +81,11 @@ async def test_history_multi_channel(
     tid = str(uuid4())
     configs: list = []
     parent_cfg = None
+    from langgraph.checkpoint.base import Checkpoint
+    from langgraph.checkpoint.base.id import uuid6
+    from langgraph.checkpoint.serde.types import _DeltaSnapshot
+
+    from langgraph.checkpoint.conformance.test_utils import generate_metadata
 
     for step in range(5):
         config = {"configurable": {"thread_id": tid, "checkpoint_ns": ""}}
@@ -157,6 +161,11 @@ async def test_history_migration_plain_value_as_seed(
     channel_values[ch] (not a _DeltaSnapshot). The walk should treat it as the
     seed and terminate there.
     """
+    from langgraph.checkpoint.base import Checkpoint
+    from langgraph.checkpoint.base.id import uuid6
+
+    from langgraph.checkpoint.conformance.test_utils import generate_metadata
+
     tid = str(uuid4())
     configs: list = []
     parent_cfg = None
@@ -199,74 +208,6 @@ async def test_history_migration_plain_value_as_seed(
     assert values == [2], f"Expected [2], got {values}"
 
 
-async def test_history_seed_ancestor_own_writes_are_replayed(
-    saver: BaseCheckpointSaver,
-) -> None:
-    """Writes stored AT the seed ancestor must be included in `writes`.
-
-    A stored value is the state ENTERING its checkpoint; the writes stored
-    under that same checkpoint are what produced its child and are therefore
-    NOT subsumed by it. Only writes at ancestors OLDER than the seed are
-    subsumed, and the walk terminates before reaching them.
-
-    This holds for plain-value seeds (migration from a pre-delta channel type)
-    exactly as it does for `_DeltaSnapshot` seeds. Skipping the seed
-    ancestor's own writes silently drops the first post-migration write.
-    """
-    tid = str(uuid4())
-    configs: list = []
-    parent_cfg = None
-
-    # Each step's write is labelled by the role it plays, so the assertion
-    # below reads directly rather than by step index.
-    writes_by_step = {
-        0: "older-than-seed",  # subsumed by the value stored at step 1
-        1: "at-seed",  # the seed's own write, produced step 2
-        2: "after-seed",  # delta-era write on the path to the head
-        3: "pending-at-head",  # pending for the next step, never replayed
-    }
-    # Steps 0 and 1 store a plain value; 1 is the nearest, so it is the seed.
-    values_by_step = {0: [10], 1: [10, 20]}
-
-    for step in range(4):
-        config = {"configurable": {"thread_id": tid, "checkpoint_ns": ""}}
-        if parent_cfg:
-            config["configurable"]["checkpoint_id"] = parent_cfg["configurable"][
-                "checkpoint_id"
-            ]
-        cv: dict = {}
-        cvs: dict = {}
-        if step in values_by_step:
-            cv["ch"] = values_by_step[step]
-            cvs["ch"] = step + 1
-        cp = Checkpoint(
-            v=1,
-            id=str(uuid6(clock_seq=-1)),
-            ts="",
-            channel_values=cv,
-            channel_versions=cvs,
-            versions_seen={},
-            updated_channels=None,
-        )
-        parent_cfg = await saver.aput(config, cp, generate_metadata(step=step), cvs)
-        configs.append(parent_cfg)
-        await saver.aput_writes(
-            parent_cfg, [("ch", writes_by_step[step])], str(uuid4())
-        )
-
-    head = configs[-1]
-    result = await saver.aget_delta_channel_history(config=head, channels=["ch"])
-
-    assert "seed" in result["ch"], "Expected seed from plain value at step 1"
-    assert result["ch"]["seed"] == [10, 20], (
-        f"Expected nearest plain value [10, 20], got {result['ch']['seed']}"
-    )
-    values = [w[2] for w in result["ch"]["writes"]]
-    assert values == ["at-seed", "after-seed"], (
-        f'Expected ["at-seed", "after-seed"], got {values}'
-    )
-
-
 ALL_DELTA_CHANNEL_HISTORY_TESTS = [
     test_history_returns_writes_oldest_first,
     test_history_seed_is_nearest_snapshot,
@@ -275,7 +216,6 @@ ALL_DELTA_CHANNEL_HISTORY_TESTS = [
     test_history_empty_channels_returns_empty,
     test_history_walk_to_root_no_seed,
     test_history_migration_plain_value_as_seed,
-    test_history_seed_ancestor_own_writes_are_replayed,
 ]
 
 

libs/checkpoint-conformance/pyproject.toml

@@ -58,14 +58,8 @@ lint.select = [
   "UP", # pyupgrade
   "B",  # flake8-bugbear
   "I",  # isort
-  "PLC0415",  # import-outside-top-level
-  "RUF100",  # unused noqa directive
 ]
 lint.ignore = ["E501", "B008"]
-# PLC0415 (import-outside-top-level) is enforced in tests only. Library code
-# still has deferred imports that have not been reviewed, so it stays exempt
-# for now.
-lint.per-file-ignores = { "langgraph/**" = ["PLC0415"] }
 target-version = "py310"
 
 [tool.uv.sources]

libs/checkpoint-postgres/README.md

@@ -67,12 +67,24 @@ with PostgresSaver.from_conn_string(DB_URI) as checkpointer:
         "v": 4,
         "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},
+        "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},
+            "__start__": {
+            "__start__": 1
+            },
+            "node": {
+            "start:node": 2
+            }
         },
     }
 
@@ -96,12 +108,24 @@ async with AsyncPostgresSaver.from_conn_string(DB_URI) as checkpointer:
         "v": 4,
         "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},
+        "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},
+            "__start__": {
+            "__start__": 1
+            },
+            "node": {
+            "start:node": 2
+            }
         },
     }
 

libs/checkpoint-postgres/langgraph/checkpoint/postgres/__init__.py

@@ -223,7 +223,7 @@ class PostgresSaver(BasePostgresSaver):
             >>> checkpoint_tuple = memory.get_tuple(config)
             >>> print(checkpoint_tuple)
             CheckpointTuple(...)
-        """
+        """  # noqa
         thread_id = config["configurable"]["thread_id"]
         checkpoint_id = get_checkpoint_id(config)
         checkpoint_ns = config["configurable"].get("checkpoint_ns", "")
@@ -478,11 +478,9 @@ class PostgresSaver(BasePostgresSaver):
         stage1_sql = _build_delta_stage1_sql(channels, paged=True)
         parent_of: dict[str, str | None] = {}
         ver_by_i_by_cid: list[dict[str, str | None]] = [{} for _ in channels]
-        hb_by_i_by_cid: list[dict[str, bool]] = [{} for _ in channels]
-        inline_by_i_by_cid: list[dict[str, Any]] = [{} for _ in channels]
+        hs_by_i_by_cid: list[dict[str, bool]] = [{} for _ in channels]
         chain_by_ch: dict[str, list[str]] = {ch: [] for ch in channels}
         seed_ver_by_ch: dict[str, str | None] = {ch: None for ch in channels}
-        seed_inline_by_ch: dict[str, Any] = {}
         walk_cursor_by_ch: dict[str, str | None] = {}
         seeded: set[str] = set()
         cursor: str | None = None
@@ -491,8 +489,7 @@ class PostgresSaver(BasePostgresSaver):
             while True:
                 stage1_params: list[Any] = []
                 for ch in channels:
-                    # ver_i, blob channel, blob version, inline_i
-                    stage1_params.extend([ch, ch, ch, ch])
+                    stage1_params.extend([ch, ch])
                 stage1_params.extend(
                     [thread_id, checkpoint_ns, cursor, cursor, _DELTA_PAGE_SIZE]
                 )
@@ -505,19 +502,16 @@ class PostgresSaver(BasePostgresSaver):
                     channels,
                     parent_of,
                     ver_by_i_by_cid,
-                    hb_by_i_by_cid,
-                    inline_by_i_by_cid,
+                    hs_by_i_by_cid,
                 )
                 self._try_advance_walks(
                     checkpoint_id,
                     channels,
                     parent_of,
                     ver_by_i_by_cid,
-                    hb_by_i_by_cid,
-                    inline_by_i_by_cid,
+                    hs_by_i_by_cid,
                     chain_by_ch,
                     seed_ver_by_ch,
-                    seed_inline_by_ch,
                     walk_cursor_by_ch,
                     seeded,
                 )
@@ -552,7 +546,6 @@ class PostgresSaver(BasePostgresSaver):
             channels=channels,
             chain_by_ch=chain_by_ch,
             seed_ver_by_ch=seed_ver_by_ch,
-            seed_inline_by_ch=seed_inline_by_ch,
             stage2_rows=cast("list[_DeltaStage2Row]", stage2_rows),
         )
 

libs/checkpoint-postgres/langgraph/checkpoint/postgres/aio.py

@@ -426,11 +426,9 @@ class AsyncPostgresSaver(BasePostgresSaver):
         stage1_sql = _build_delta_stage1_sql(channels, paged=True)
         parent_of: dict[str, str | None] = {}
         ver_by_i_by_cid: list[dict[str, str | None]] = [{} for _ in channels]
-        hb_by_i_by_cid: list[dict[str, bool]] = [{} for _ in channels]
-        inline_by_i_by_cid: list[dict[str, Any]] = [{} for _ in channels]
+        hs_by_i_by_cid: list[dict[str, bool]] = [{} for _ in channels]
         chain_by_ch: dict[str, list[str]] = {ch: [] for ch in channels}
         seed_ver_by_ch: dict[str, str | None] = {ch: None for ch in channels}
-        seed_inline_by_ch: dict[str, Any] = {}
         walk_cursor_by_ch: dict[str, str | None] = {}
         seeded: set[str] = set()
         cursor: str | None = None
@@ -439,8 +437,7 @@ class AsyncPostgresSaver(BasePostgresSaver):
             while True:
                 stage1_params: list[Any] = []
                 for ch in channels:
-                    # ver_i, blob channel, blob version, inline_i
-                    stage1_params.extend([ch, ch, ch, ch])
+                    stage1_params.extend([ch, ch])
                 stage1_params.extend(
                     [thread_id, checkpoint_ns, cursor, cursor, _DELTA_PAGE_SIZE]
                 )
@@ -453,19 +450,16 @@ class AsyncPostgresSaver(BasePostgresSaver):
                     channels,
                     parent_of,
                     ver_by_i_by_cid,
-                    hb_by_i_by_cid,
-                    inline_by_i_by_cid,
+                    hs_by_i_by_cid,
                 )
                 self._try_advance_walks(
                     checkpoint_id,
                     channels,
                     parent_of,
                     ver_by_i_by_cid,
-                    hb_by_i_by_cid,
-                    inline_by_i_by_cid,
+                    hs_by_i_by_cid,
                     chain_by_ch,
                     seed_ver_by_ch,
-                    seed_inline_by_ch,
                     walk_cursor_by_ch,
                     seeded,
                 )
@@ -496,7 +490,6 @@ class AsyncPostgresSaver(BasePostgresSaver):
             channels=channels,
             chain_by_ch=chain_by_ch,
             seed_ver_by_ch=seed_ver_by_ch,
-            seed_inline_by_ch=seed_inline_by_ch,
             stage2_rows=cast("list[_DeltaStage2Row]", stage2_rows),
         )
 
@@ -580,7 +573,7 @@ class AsyncPostgresSaver(BasePostgresSaver):
         while True:
             try:
                 yield asyncio.run_coroutine_threadsafe(
-                    anext(aiter_),  # type: ignore[arg-type]
+                    anext(aiter_),  # type: ignore[arg-type]  # noqa: F821
                     self.loop,
                 ).result()
             except StopAsyncIteration:

libs/checkpoint-postgres/langgraph/checkpoint/postgres/base.py

@@ -199,68 +199,27 @@ class _DeltaStage2Row(TypedDict, total=False):
 
 
 def _build_delta_stage1_sql(channels: Sequence[str], *, paged: bool) -> str:
-    """Build stage 1 SQL with K parallel version lookups + seed probes.
+    """Build stage 1 SQL with 2K parallel JSONB key lookups.
 
     For channels=["messages", "files"] (with `paged=True`) the result is::
 
         SELECT checkpoint_id, parent_checkpoint_id,
                checkpoint -> 'channel_versions' ->> %s AS ver_0,
-               EXISTS (SELECT 1 FROM checkpoint_blobs b0
-                       WHERE b0.thread_id = checkpoints.thread_id
-                         AND b0.checkpoint_ns = checkpoints.checkpoint_ns
-                         AND b0.channel = %s
-                         AND b0.version = checkpoint -> 'channel_versions' ->> %s
-                         AND b0.type <> 'empty') AS hb_0,
-               checkpoint -> 'channel_values' -> %s AS inline_0,
+               (checkpoint -> 'channel_values' -> %s) IS NOT NULL AS hs_0,
                checkpoint -> 'channel_versions' ->> %s AS ver_1,
-               EXISTS (...) AS hb_1,
-               checkpoint -> 'channel_values' -> %s AS inline_1
+               (checkpoint -> 'channel_values' -> %s) IS NOT NULL AS hs_1
         FROM checkpoints
         WHERE thread_id = %s AND checkpoint_ns = %s
           AND (%s::text IS NULL OR checkpoint_id < %s)
         ORDER BY checkpoint_id DESC
         LIMIT %s
 
-    A stored value for a channel lives in one of two places, because `put`
-    splits them:
-
-    * **blob** — non-primitive values (and `_DeltaSnapshot`) are moved to
-      `checkpoint_blobs`. `hb_i` ("has blob") probes for one. The probe hits
-      that table's primary key `(thread_id, checkpoint_ns, channel, version)`
-      exactly, so it is an index lookup per row per channel.
-    * **inline** — `None`, `str`, `int`, `float` and `bool` stay in the
-      checkpoint's own `channel_values` and get no blob row at all. `inline_i`
-      returns that value.
-
-    Testing only for a key in `channel_values` (the previous approach) missed
-    blob-stored plain values, since `put` leaves an inline marker there for
-    `_DeltaSnapshot` but not for a plain value — which is what a thread
-    migrated from a pre-delta channel type leaves behind. Probing only the
-    blobs table would conversely miss inline primitives. Both are needed, and
-    the caller treats "either present" as the seed.
-
-    `hb_i` also disambiguates the two: for a `_DeltaSnapshot`, `inline_i` is the
-    literal `true` marker rather than the value, so a blob must win over an
-    inline reading whenever one exists. That ordering is what makes a genuine
-    inline `true` (a bool channel) distinguishable from the marker.
-
-    The `type <> 'empty'` predicate mirrors the check stage 2 already applies
-    when resolving the seed blob. `put` does not currently produce `empty` rows
-    on this path — `blob_versions` is filtered to keys present in
-    `channel_values`, so `_dump_blobs`' empty branch is unreachable from it —
-    but without the predicate the two stages could disagree: stage 1 would
-    terminate the walk on a row stage 2 then discards, yielding no seed *and* a
-    truncated write chain, which is the failure this function exists to avoid.
-
     Channel names are passed as `%s` parameters (safe from SQL injection).
-    Only the column aliases `ver_i` / `hb_i` / `inline_i` and the subquery alias
-    `b{i}` are interpolated into the SQL string (i is bounded by len(channels)
-    and uses safe identifiers).
+    Only the column aliases `ver_i` / `hs_i` are interpolated into the
+    SQL string (i is bounded by len(channels) and uses safe identifiers).
 
-    Caller must extend params with `[ch_0 x4, ch_1 x4, ..., thread_id, ns,
-    cursor, cursor, page_size]` when `paged=True` — four per channel: the
-    version lookup, the blob's channel, the version the blob must match, and the
-    inline lookup.
+    Caller must extend params with `[ch_0, ch_0, ch_1, ch_1, ...,
+    thread_id, ns, cursor, cursor, page_size]` when `paged=True`.
 
     When `paged=False`, the WHERE has no cursor predicate and there's no
     LIMIT/ORDER BY — kept as a non-public helper for tests/diagnostics.
@@ -269,13 +228,7 @@ def _build_delta_stage1_sql(channels: Sequence[str], *, paged: bool) -> str:
     for i in range(len(channels)):
         cols.append(
             f"checkpoint -> 'channel_versions' ->> %s AS ver_{i}, "
-            f"EXISTS (SELECT 1 FROM checkpoint_blobs b{i} "
-            f"WHERE b{i}.thread_id = checkpoints.thread_id "
-            f"AND b{i}.checkpoint_ns = checkpoints.checkpoint_ns "
-            f"AND b{i}.channel = %s "
-            f"AND b{i}.version = checkpoint -> 'channel_versions' ->> %s "
-            f"AND b{i}.type <> 'empty') AS hb_{i}, "
-            f"checkpoint -> 'channel_values' -> %s AS inline_{i}"
+            f"(checkpoint -> 'channel_values' -> %s) IS NOT NULL AS hs_{i}"
         )
     sql = (
         "SELECT checkpoint_id, parent_checkpoint_id, "
@@ -389,8 +342,7 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
         channels: Sequence[str],
         parent_of: dict[str, str | None],
         ver_by_i_by_cid: list[dict[str, str | None]],
-        hb_by_i_by_cid: list[dict[str, bool]],
-        inline_by_i_by_cid: list[dict[str, Any]],
+        hs_by_i_by_cid: list[dict[str, bool]],
     ) -> str | None:
         """Fold one stage-1 page into the running walk-state mappings.
 
@@ -404,8 +356,7 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
             parent_of[cid] = cast("str | None", r["parent_checkpoint_id"])
             for i in range(len(channels)):
                 ver_by_i_by_cid[i][cid] = cast("str | None", r.get(f"ver_{i}"))
-                hb_by_i_by_cid[i][cid] = bool(r.get(f"hb_{i}"))
-                inline_by_i_by_cid[i][cid] = r.get(f"inline_{i}")
+                hs_by_i_by_cid[i][cid] = bool(r.get(f"hs_{i}"))
             # Rows are DESC; the last one is the smallest cid in the page.
             oldest = cid
         return oldest
@@ -416,11 +367,9 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
         channels: Sequence[str],
         parent_of: Mapping[str, str | None],
         ver_by_i_by_cid: Sequence[Mapping[str, str | None]],
-        hb_by_i_by_cid: Sequence[Mapping[str, bool]],
-        inline_by_i_by_cid: Sequence[Mapping[str, Any]],
+        hs_by_i_by_cid: Sequence[Mapping[str, bool]],
         chain_by_ch: dict[str, list[str]],
         seed_ver_by_ch: dict[str, str | None],
-        seed_inline_by_ch: dict[str, Any],
         walk_cursor_by_ch: dict[str, str | None],
         seeded: set[str],
     ) -> None:
@@ -428,15 +377,14 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
 
         Uses the partial `parent_of` map accumulated so far. A walk stops
         either because:
-          (a) it found a stored value for its channel — a blob or an inline
-              primitive (channel becomes seeded),
+          (a) it found a snapshot for its channel (channel becomes seeded),
           (b) it reached a real root (parent_of[cid] is None — fully
               materialized at this point), or
           (c) the next ancestor cid isn't in `parent_of` yet (waiting for
               a later page; the cursor stays put).
 
-        Mutates `chain_by_ch`, `seed_ver_by_ch`, `seed_inline_by_ch`,
-        `walk_cursor_by_ch`, and `seeded` in place.
+        Mutates `chain_by_ch`, `seed_ver_by_ch`, `walk_cursor_by_ch`, and
+        `seeded` in place.
         """
         for i, ch in enumerate(channels):
             if ch in seeded:
@@ -446,22 +394,15 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
                 walk_cursor_by_ch[ch] = parent_of.get(target_id)
             cur_cid = walk_cursor_by_ch[ch]
             ch_chain = chain_by_ch[ch]
-            hb_i = hb_by_i_by_cid[i]
-            inline_i = inline_by_i_by_cid[i]
+            hs_i = hs_by_i_by_cid[i]
             ver_i = ver_by_i_by_cid[i]
             while cur_cid is not None:
                 if cur_cid not in parent_of:
                     # Need more pages to continue this walk.
                     break
                 ch_chain.append(cur_cid)
-                has_blob = hb_i.get(cur_cid, False)
-                inline = inline_i.get(cur_cid)
-                if has_blob or inline is not None:
-                    # A blob wins: for a `_DeltaSnapshot` the inline reading is
-                    # the `true` marker, not the value.
+                if hs_i.get(cur_cid, False):
                     seed_ver_by_ch[ch] = ver_i.get(cur_cid)
-                    if not has_blob:
-                        seed_inline_by_ch[ch] = inline
                     seeded.add(ch)
                     cur_cid = None
                     break
@@ -474,23 +415,16 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
         channels: Sequence[str],
         chain_by_ch: Mapping[str, list[str]],
         seed_ver_by_ch: Mapping[str, str | None],
-        seed_inline_by_ch: Mapping[str, Any],
         stage2_rows: Sequence[_DeltaStage2Row],
     ) -> dict[str, DeltaChannelHistory]:
         """Demux stage 2 rows per channel; produce per-channel histories.
 
         stage2_rows carry `channel` on every row. We build per-channel
         `writes_by_cid` and per-channel `seed_blob` dicts, then assemble
-        a `DeltaChannelHistory` per requested channel.
-
-        A seed comes from the blobs table when the walk found one there, and
-        otherwise from `seed_inline_by_ch` — `put` keeps `None`, `str`, `int`,
-        `float` and `bool` values in the checkpoint's own `channel_values` with
-        no blob row, so those never appear in `stage2_rows`.
-
-        The `seed` key is omitted when the walk reached root without finding a
-        stored value, or when the seed blob is sentinel "empty" — in both cases
-        the consumer treats absence as "start empty".
+        a `DeltaChannelHistory` per requested channel. The `seed` key is omitted
+        when the walk reached root with no snapshot found, or when the
+        seed blob is sentinel "empty" — in both cases the consumer treats
+        absence as "start empty".
         """
         # writes_by_ch_by_cid[channel][cid] = list of (type, blob, task_id, idx)
         writes_by_ch_by_cid: dict[str, dict[str, list[tuple[str, bytes, str, int]]]] = {
@@ -539,10 +473,6 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
                 blob = seed_blob_by_ver.get((ch, seed_version))
                 if blob is not None and blob[0] != "empty":
                     entry["seed"] = self.serde.loads_typed(blob)
-                elif ch in seed_inline_by_ch:
-                    # Inline primitive: stored in the checkpoint, not the blobs
-                    # table, so stage 2 never returned a row for it.
-                    entry["seed"] = seed_inline_by_ch[ch]
             result[ch] = entry
         return result
 

libs/checkpoint-postgres/langgraph/checkpoint/postgres/shallow.py

@@ -334,7 +334,7 @@ class ShallowPostgresSaver(BasePostgresSaver):
             >>> checkpoint_tuple = memory.get_tuple(config)
             >>> print(checkpoint_tuple)
             CheckpointTuple(...)
-        """
+        """  # noqa
         thread_id = config["configurable"]["thread_id"]
         checkpoint_ns = config["configurable"].get("checkpoint_ns", "")
         args = (thread_id, checkpoint_ns)
@@ -885,7 +885,7 @@ class AsyncShallowPostgresSaver(BasePostgresSaver):
         while True:
             try:
                 yield asyncio.run_coroutine_threadsafe(
-                    anext(aiter_),  # type: ignore[arg-type]
+                    anext(aiter_),  # type: ignore[arg-type]  # noqa: F821
                     self.loop,
                 ).result()
             except StopAsyncIteration:

libs/checkpoint-postgres/langgraph/store/postgres/base.py

@@ -4,10 +4,9 @@ import asyncio
 import concurrent.futures
 import json
 import logging
-import re
 import threading
 from collections import defaultdict
-from collections.abc import Callable, Iterable, Iterator, Mapping, Sequence
+from collections.abc import Callable, Iterable, Iterator, Sequence
 from contextlib import contextmanager
 from datetime import datetime
 from typing import (
@@ -239,12 +238,6 @@ class BasePostgresStore(Generic[C]):
     conn: C
     _deserializer: Callable[[bytes | orjson.Fragment], dict[str, Any]] | None
     index_config: PostgresIndexConfig | None
-    ttl_config: TTLConfig | None
-
-    @property
-    def _omit_expired(self) -> bool:
-        """Whether expired-but-unswept rows should be filtered from reads."""
-        return bool(self.ttl_config and self.ttl_config.get("omit_expired"))
 
     def _get_batch_GET_ops_queries(
         self,
@@ -265,17 +258,12 @@ class BasePostgresStore(Generic[C]):
             namespace_groups[op.namespace].append((idx, op.key))
             refresh_ttls[op.namespace].append(op.refresh_ttl)
 
-        omit_expired = self._omit_expired
-        expiry_clause = (
-            "AND (s.expires_at IS NULL OR s.expires_at > NOW())" if omit_expired else ""
-        )
-
         results = []
         for namespace, items in namespace_groups.items():
             _, keys = zip(*items, strict=False)
             this_refresh_ttls = refresh_ttls[namespace]
 
-            query = f"""
+            query = """
                 WITH passed_in AS (
                     SELECT unnest(%s::text[]) AS key,
                         unnest(%s::bool[])  AS do_refresh
@@ -288,14 +276,12 @@ class BasePostgresStore(Generic[C]):
                     AND s.key    = p.key
                     AND p.do_refresh = TRUE
                     AND s.ttl_minutes IS NOT NULL
-                    {expiry_clause}
                     RETURNING s.key
                 )
                 SELECT s.key, s.value, s.created_at, s.updated_at
                 FROM store s
                 JOIN passed_in p ON s.key = p.key
                 WHERE s.prefix = %s
-                {expiry_clause}
             """
             ns_text = _namespace_to_text(namespace)
             params = (
@@ -354,7 +340,7 @@ class BasePostgresStore(Generic[C]):
                     (
                         _namespace_to_text(op.namespace),
                         op.key,
-                        Jsonb(dict(cast(Mapping[str, Any], op.value))),
+                        Jsonb(cast(dict, op.value)),
                     )
                 )
                 if op.ttl is not None:
@@ -436,13 +422,6 @@ class BasePostgresStore(Generic[C]):
         - embedding_requests: list of (original_index_in_search_ops, text_query)
         """
 
-        omit_expired = self._omit_expired
-        search_expiry_clause = (
-            "AND (store.expires_at IS NULL OR store.expires_at > NOW())"
-            if omit_expired
-            else ""
-        )
-
         queries = []
         embedding_requests = []
         for idx, (_, op) in enumerate(search_ops):
@@ -464,9 +443,8 @@ class BasePostgresStore(Generic[C]):
             ns_condition = "TRUE"
             ns_param: Sequence[str] | None = None
             if op.namespace_prefix:
-                ns_condition, ns_param = _namespace_prefix_condition(
-                    op.namespace_prefix
-                )
+                ns_condition = "store.prefix LIKE %s"
+                ns_param = (f"{_namespace_to_text(op.namespace_prefix)}%",)
             else:
                 ns_param = ()
 
@@ -513,7 +491,7 @@ class BasePostgresStore(Generic[C]):
                             {score_operator} AS neg_score
                         FROM store
                         JOIN store_vectors sv ON store.prefix = sv.prefix AND store.key = sv.key
-                        WHERE {ns_condition} {extra_filters} {search_expiry_clause}
+                        WHERE {ns_condition} {extra_filters}
                         ORDER BY {score_operator} ASC
                         LIMIT %s
                     """
@@ -549,7 +527,7 @@ class BasePostgresStore(Generic[C]):
                 base_query = f"""
                         SELECT store.prefix, store.key, store.value, store.created_at, store.updated_at, NULL AS score
                         FROM store
-                        WHERE {ns_condition} {extra_filters} {search_expiry_clause}
+                        WHERE {ns_condition} {extra_filters}
                         ORDER BY store.updated_at DESC
                         LIMIT %s
                         OFFSET %s
@@ -613,23 +591,18 @@ class BasePostgresStore(Generic[C]):
             """
             params: list[Any] = [op.max_depth, op.max_depth]
 
-            omit_expired = self._omit_expired
             conditions = []
-            if omit_expired:
-                conditions.append("(expires_at IS NULL OR expires_at > NOW())")
             if op.match_conditions:
                 for condition in op.match_conditions:
-                    if condition.match_type in ("prefix", "suffix"):
-                        if not condition.path:
-                            # An empty path constrains nothing; skipping keeps it a
-                            # no-op rather than emitting a pattern that matches no
-                            # namespace at all.
-                            continue
-                        conditions.append("prefix ~ %s")
+                    if condition.match_type == "prefix":
+                        conditions.append("prefix LIKE %s")
                         params.append(
-                            _namespace_match_pattern(
-                                condition.path, condition.match_type
-                            )
+                            f"{_namespace_to_text(condition.path, handle_wildcards=True)}%"
+                        )
+                    elif condition.match_type == "suffix":
+                        conditions.append("prefix LIKE %s")
+                        params.append(
+                            f"%{_namespace_to_text(condition.path, handle_wildcards=True)}"
                         )
                     else:
                         logger.warning(
@@ -1275,59 +1248,15 @@ def _get_index_params(store: Any) -> tuple[str, dict[str, Any]]:
     return kind, sanitized
 
 
-def _namespace_to_text(namespace: tuple[str, ...]) -> str:
+def _namespace_to_text(
+    namespace: tuple[str, ...], handle_wildcards: bool = False
+) -> str:
     """Convert namespace tuple to text string."""
+    if handle_wildcards:
+        namespace = tuple("%" if val == "*" else val for val in namespace)
     return ".".join(namespace)
 
 
-def _escape_like_literal(text: str) -> str:
-    """Escape LIKE metacharacters so `text` is matched literally.
-
-    Namespace labels may contain `_` and `%`, which would otherwise act as
-    wildcards: `("user_1",)` would match `("userX1",)`. Backslash is escaped
-    first so it cannot escape the following character. Requires an explicit
-    `ESCAPE '\\'` clause on the pattern.
-    """
-    return text.replace("\\", "\\\\").replace("%", "\\%").replace("_", "\\_")
-
-
-def _namespace_prefix_condition(namespace_prefix: tuple[str, ...]) -> tuple[str, tuple]:
-    """Build the SQL scoping a search to a namespace and its descendants.
-
-    Matches the namespace exactly or requires the `.` separator before any
-    remainder, so a prefix of `("foo",)` does not also match `("foobar",)`.
-
-    Both arms stay index-friendly: equality on the `(prefix, key)` primary key,
-    the anchored LIKE on the `prefix text_pattern_ops` index.
-
-    Only the LIKE arm is escaped -- equality does not interpret metacharacters,
-    so escaping it would stop `("user_1",)` from matching itself.
-    """
-    path = _namespace_to_text(namespace_prefix)
-    condition = r"(store.prefix = %s OR store.prefix LIKE %s ESCAPE '\')"
-    return condition, (path, f"{_escape_like_literal(path)}.%")
-
-
-def _namespace_match_pattern(path: tuple[str, ...], match_type: str) -> str:
-    """Build a POSIX regex matching the dot-joined prefix on whole segments.
-
-    Needed because `LIKE` cannot express "any character except the separator".
-    Matches how `InMemoryStore` compares namespaces element-wise.
-
-    `*` matches exactly one segment. Prefix matches stay open-ended but must end
-    on a separator; suffix matches anchor at the end and begin on one.
-
-    Examples:
-        prefix ("uid", "*", "alice") -> ^uid\\.[^.]+\\.alice(\\.|\\Z)
-        suffix ("alice",)            -> (^|\\.)alice\\Z
-    """
-    segments = ("[^.]+" if part == "*" else re.escape(part) for part in path)
-    body = r"\.".join(segments)
-    if match_type == "suffix":
-        return rf"(^|\.){body}\Z"
-    return rf"^{body}(\.|\Z)"
-
-
 def _row_to_item(
     namespace: tuple[str, ...],
     row: Row,

libs/checkpoint-postgres/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "langgraph-checkpoint-postgres"
-version = "3.1.2"
+version = "3.1.0"
 description = "Library with a Postgres implementation of LangGraph checkpoint saver."
 authors = []
 requires-python = ">=3.10"
@@ -32,7 +32,6 @@ test = [
   "pytest-mock",
   "psycopg[binary]",
   "langgraph-checkpoint",
-  "langgraph-checkpoint-conformance",
   "pytest-watcher",
 ]
 lint = [
@@ -50,7 +49,6 @@ default-groups = ['dev']
 
 [tool.uv.sources]
 langgraph-checkpoint = { path = "../checkpoint", editable = true }
-langgraph-checkpoint-conformance = { path = "../checkpoint-conformance", editable = true }
 
 [tool.hatch.build.targets.wheel]
 include = ["langgraph"]
@@ -66,8 +64,6 @@ lint.select = [
   "UP", # pyupgrade
   "B",  # flake8-bugbear
   "I",  # isort
-  "PLC0415",  # import-outside-top-level
-  "RUF100",  # unused noqa directive
   "UP", # pyupgrade
 ]
 lint.ignore = ["E501", "B008"]

libs/checkpoint-postgres/tests/test_async.py

@@ -380,15 +380,13 @@ async def test_delta_channel_chain_reconstruction(saver_name: str) -> None:
         "langgraph.channels.delta", reason="langgraph core not installed"
     )
 
-    # Deferred on purpose: langgraph core is not a test dependency of this
-    # package, so these must stay behind the importorskip above.
-    from typing import Annotated  # noqa: PLC0415
+    from typing import Annotated
 
-    from langchain_core.messages import AIMessage, HumanMessage  # noqa: PLC0415
-    from langgraph.channels.delta import DeltaChannel  # noqa: PLC0415
-    from langgraph.graph import START, StateGraph  # noqa: PLC0415
-    from langgraph.graph.message import _messages_delta_reducer  # noqa: PLC0415
-    from typing_extensions import TypedDict  # noqa: PLC0415
+    from langchain_core.messages import AIMessage, HumanMessage
+    from langgraph.channels.delta import DeltaChannel
+    from langgraph.graph import START, StateGraph
+    from langgraph.graph.message import _messages_delta_reducer
+    from typing_extensions import TypedDict
 
     class State(TypedDict):
         messages: Annotated[list, DeltaChannel(_messages_delta_reducer)]

libs/checkpoint-postgres/tests/test_async_store.py

@@ -739,135 +739,3 @@ async def test_store_ttl(store):
     # Now has been (TTL_SECONDS-2)*2 > TTL_SECONDS + TTL_SECONDS/2
     results = await store.asearch(ns, query="bar", refresh_ttl=False)
     assert len(results) == 0
-
-
-async def _aexpire_now(
-    store: AsyncPostgresStore, ns: tuple[str, ...], key: str
-) -> None:
-    """Backdate a row's expires_at into the past without deleting it (unswept)."""
-    async with store._cursor() as cur:
-        await cur.execute(
-            "UPDATE store SET expires_at = NOW() - INTERVAL '1 minute' "
-            "WHERE prefix = %s AND key = %s",
-            (".".join(ns), key),
-        )
-
-
-async def _arow_exists(
-    store: AsyncPostgresStore, ns: tuple[str, ...], key: str
-) -> bool:
-    async with store._cursor() as cur:
-        await cur.execute(
-            "SELECT COUNT(*) AS n FROM store WHERE prefix = %s AND key = %s",
-            (".".join(ns), key),
-        )
-        return (await cur.fetchone())["n"] == 1
-
-
-async def _astored_expires_at(store: AsyncPostgresStore, ns: tuple[str, ...], key: str):
-    async with store._cursor() as cur:
-        await cur.execute(
-            "SELECT expires_at FROM store WHERE prefix = %s AND key = %s",
-            (".".join(ns), key),
-        )
-        return (await cur.fetchone())["expires_at"]
-
-
-async def test_omit_expired_filters_read_paths(store: AsyncPostgresStore) -> None:
-    await store.stop_ttl_sweeper()  # deterministic: no background deletion
-    store.ttl_config["omit_expired"] = True
-
-    expired_ns = ("omit", "expired")
-    control_ns = ("omit", "control")
-    await store.aput(expired_ns, "e", {"data": "gone"}, ttl=TTL_MINUTES)
-    await store.aput(control_ns, "c", {"data": "keep"}, ttl=None)
-    await _aexpire_now(store, expired_ns, "e")
-
-    # The row is expired but physically still present (unswept).
-    assert await _arow_exists(store, expired_ns, "e")
-
-    # aget omits it; the never-expiring control is still returned.
-    assert await store.aget(expired_ns, "e") is None
-    assert await store.aget(control_ns, "c") is not None
-
-    # asearch omits it but returns the control.
-    assert await store.asearch(expired_ns) == []
-    assert [i.key for i in await store.asearch(control_ns)] == ["c"]
-
-    # alist_namespaces drops the expired-only namespace, keeps the control.
-    namespaces = await store.alist_namespaces(prefix=("omit",))
-    assert expired_ns not in namespaces
-    assert control_ns in namespaces
-
-
-@pytest.mark.parametrize("omit", [None, False], ids=["default", "explicit-false"])
-async def test_omit_expired_disabled_preserves_expired_rows(
-    store: AsyncPostgresStore, omit
-) -> None:
-    await store.stop_ttl_sweeper()
-    if omit is not None:
-        store.ttl_config["omit_expired"] = omit
-
-    ns = ("keep",)
-    await store.aput(ns, "k", {"data": "still-here"}, ttl=TTL_MINUTES)
-    await _aexpire_now(store, ns, "k")
-
-    assert await store.aget(ns, "k", refresh_ttl=False) is not None
-    assert [i.key for i in await store.asearch(ns, refresh_ttl=False)] == ["k"]
-    assert ns in await store.alist_namespaces(prefix=("keep",))
-
-
-async def test_omit_expired_refresh_ttl_only_refreshes_live_rows(
-    store: AsyncPostgresStore,
-) -> None:
-    await store.stop_ttl_sweeper()
-    store.ttl_config["omit_expired"] = True
-
-    ns = ("refresh",)
-    await store.aput(ns, "expired", {"n": 0}, ttl=TTL_MINUTES)
-    await store.aput(ns, "live_get", {"n": 1}, ttl=TTL_MINUTES)
-    await store.aput(ns, "live_search", {"n": 2}, ttl=TTL_MINUTES)
-    await _aexpire_now(store, ns, "expired")
-
-    expired_before = await _astored_expires_at(store, ns, "expired")
-    get_before = await _astored_expires_at(store, ns, "live_get")
-    search_before = await _astored_expires_at(store, ns, "live_search")
-
-    # refresh_ttl=True must NOT resurrect the expired row (via aget or asearch)...
-    assert await store.aget(ns, "expired", refresh_ttl=True) is None
-    live_keys = [i.key for i in await store.asearch(ns, refresh_ttl=True)]
-    assert "expired" not in live_keys
-    assert await _astored_expires_at(store, ns, "expired") == expired_before
-
-    # ...but must still extend the live rows that were read.
-    assert await store.aget(ns, "live_get", refresh_ttl=True) is not None
-    assert await _astored_expires_at(store, ns, "live_get") > get_before
-    assert await _astored_expires_at(store, ns, "live_search") > search_before
-
-
-async def test_omit_expired_search_pagination(store: AsyncPostgresStore) -> None:
-    await store.stop_ttl_sweeper()
-    store.ttl_config["omit_expired"] = True
-
-    ns = ("page",)
-    for k in ("a", "b", "c"):
-        await store.aput(ns, k, {"k": k}, ttl=TTL_MINUTES)
-    await store.aput(ns, "expired", {"k": "x"}, ttl=TTL_MINUTES)
-    await _aexpire_now(store, ns, "expired")
-
-    seconds_ago = {"a": 1, "expired": 2, "b": 3, "c": 4}
-    # updated_at DESC orders these a, expired, b, c, so the expired row sits inside
-    # the first limit=2 window. Correct (pre-LIMIT) filtering yields live pages
-    # [a, b] then [c]; post-LIMIT filtering would underfill page 1 to just [a].
-    async with store._cursor() as cur:
-        for key, secs in seconds_ago.items():
-            await cur.execute(
-                "UPDATE store SET updated_at = NOW() - (%s * INTERVAL '1 second') "
-                "WHERE prefix = %s AND key = %s",
-                (secs, ".".join(ns), key),
-            )
-
-    page1 = await store.asearch(ns, limit=2, offset=0)
-    page2 = await store.asearch(ns, limit=2, offset=2)
-    assert [i.key for i in page1] == ["a", "b"]
-    assert [i.key for i in page2] == ["c"]

libs/checkpoint-postgres/tests/test_conformance_delta.py

@@ -1,30 +0,0 @@
-"""Run delta-channel conformance capabilities against AsyncPostgresSaver."""
-
-from __future__ import annotations
-
-import pytest
-from langgraph.checkpoint.conformance import validate
-from langgraph.checkpoint.conformance.initializer import checkpointer_test
-
-from langgraph.checkpoint.postgres.aio import AsyncPostgresSaver
-from tests.conftest import DEFAULT_URI
-
-
-@pytest.mark.asyncio
-async def test_delta_channel_conformance():
-    @checkpointer_test(name="AsyncPostgresSaver")
-    async def postgres_saver():
-        async with AsyncPostgresSaver.from_conn_string(DEFAULT_URI) as saver:
-            await saver.setup()
-            yield saver
-
-    report = await validate(
-        postgres_saver,
-        capabilities={
-            "delta_channel_history",
-        },
-    )
-    for cap, result in report.results.items():
-        if result.passed is False:
-            details = "\n".join(result.failures or [])
-            pytest.fail(f"Capability {cap} failed:\n{details}")

libs/checkpoint-postgres/tests/test_delta_plain_value_seed.py

@@ -1,204 +0,0 @@
-"""Seed detection for `DeltaChannel` histories on Postgres.
-
-`put` splits stored values in two: primitives stay inline in the checkpoint's
-`channel_values`, everything else moves to `checkpoint_blobs`. Only
-`_DeltaSnapshot` leaves an inline marker behind when it moves, so the stage-1
-walk has to check both places — a blob probe alone misses inline primitives, and
-an inline-key check alone missed blob-stored plain values, which is what a thread
-migrated from a pre-delta channel type leaves behind. See #8534.
-"""
-
-from __future__ import annotations
-
-from typing import Any
-from uuid import uuid4
-
-import pytest
-from langgraph.checkpoint.base import Checkpoint, empty_checkpoint
-from langgraph.checkpoint.base.id import uuid6
-from langgraph.checkpoint.serde.types import _DeltaSnapshot
-
-from langgraph.checkpoint.postgres.aio import AsyncPostgresSaver
-from tests.conftest import DEFAULT_URI
-
-CHANNEL = "items"
-
-
-async def _build_chain(saver: AsyncPostgresSaver, seed_value: Any) -> tuple[str, dict]:
-    """Store `seed_value` at step 1, then two steps that store nothing.
-
-    Every step carries a write so the walk has something to collect.
-    Returns `(thread_id, head_config)`.
-    """
-    thread_id = str(uuid4())
-    parent: dict | None = None
-    for step in range(4):
-        config: dict = {"configurable": {"thread_id": thread_id, "checkpoint_ns": ""}}
-        if parent is not None:
-            config["configurable"]["checkpoint_id"] = parent["configurable"][
-                "checkpoint_id"
-            ]
-        cp: Checkpoint = empty_checkpoint()
-        cp["id"] = str(uuid6(clock_seq=step))
-        new_versions: dict[str, Any] = {}
-        if step == 1:
-            cp["channel_values"][CHANNEL] = seed_value
-            cp["channel_versions"][CHANNEL] = "v1"
-            new_versions[CHANNEL] = "v1"
-        else:
-            cp["channel_versions"][CHANNEL] = f"v{step}"
-        parent = await saver.aput(
-            config, cp, {"source": "loop", "step": step, "parents": {}}, new_versions
-        )
-        await saver.aput_writes(parent, [(CHANNEL, f"w{step}")], str(uuid4()))
-    assert parent is not None
-    return thread_id, parent
-
-
-@pytest.mark.asyncio
-async def test_plain_value_seed_is_found() -> None:
-    """A pre-delta plain value must be located as the seed.
-
-    Before #8534 the walk ran to the root and returned no seed, which happens
-    to reconstruct correctly for additive reducers while costing an
-    O(thread length) replay on every read.
-    """
-    async with AsyncPostgresSaver.from_conn_string(DEFAULT_URI) as saver:
-        await saver.setup()
-        _, head = await _build_chain(saver, [10, 20])
-
-        result = await saver.aget_delta_channel_history(config=head, channels=[CHANNEL])
-        entry = result[CHANNEL]
-
-        assert entry.get("seed") == [10, 20], (
-            f"expected the plain value as seed, got {entry.get('seed', '<missing>')}"
-        )
-        # Only the writes between the seed and the head's parent replay: step 1
-        # (the seed's own) and step 2. Step 0 is older than the seed, step 3 is
-        # pending at the head.
-        assert [w[2] for w in entry["writes"]] == ["w1", "w2"]
-
-
-@pytest.mark.asyncio
-async def test_delta_snapshot_seed_is_found() -> None:
-    """The `_DeltaSnapshot` path keeps working, so both seed kinds agree."""
-    async with AsyncPostgresSaver.from_conn_string(DEFAULT_URI) as saver:
-        await saver.setup()
-        _, head = await _build_chain(saver, _DeltaSnapshot([10, 20]))
-
-        result = await saver.aget_delta_channel_history(config=head, channels=[CHANNEL])
-        entry = result[CHANNEL]
-
-        seed = entry.get("seed")
-        assert isinstance(seed, _DeltaSnapshot), f"expected a snapshot, got {seed!r}"
-        assert seed.value == [10, 20]
-        assert [w[2] for w in entry["writes"]] == ["w1", "w2"]
-
-
-@pytest.mark.asyncio
-async def test_version_bump_without_a_value_does_not_hide_an_older_seed() -> None:
-    """A delta-era step bumps `channel_versions` without storing a value, so no
-    blob exists for that version. The probe must report no seed there and keep
-    walking rather than stopping at a version it cannot resolve.
-
-    Step 0 holds the real value; step 1 bumps the version with nothing stored.
-    Walking back from the head has to pass step 1 to reach step 0.
-    """
-    async with AsyncPostgresSaver.from_conn_string(DEFAULT_URI) as saver:
-        await saver.setup()
-        thread_id = str(uuid4())
-        parent: dict | None = None
-        for step in range(4):
-            config: dict = {
-                "configurable": {"thread_id": thread_id, "checkpoint_ns": ""}
-            }
-            if parent is not None:
-                config["configurable"]["checkpoint_id"] = parent["configurable"][
-                    "checkpoint_id"
-                ]
-            cp: Checkpoint = empty_checkpoint()
-            cp["id"] = str(uuid6(clock_seq=step))
-            new_versions: dict[str, Any] = {}
-            if step == 0:
-                cp["channel_values"][CHANNEL] = [10, 20]
-                cp["channel_versions"][CHANNEL] = "v0"
-                new_versions[CHANNEL] = "v0"
-            elif step == 1:
-                # Version bumped, value absent -> no blob row written.
-                cp["channel_versions"][CHANNEL] = "v1"
-                new_versions[CHANNEL] = "v1"
-            else:
-                cp["channel_versions"][CHANNEL] = "v1"
-            parent = await saver.aput(
-                config,
-                cp,
-                {"source": "loop", "step": step, "parents": {}},
-                new_versions,
-            )
-            await saver.aput_writes(parent, [(CHANNEL, f"w{step}")], str(uuid4()))
-        assert parent is not None
-
-        result = await saver.aget_delta_channel_history(
-            config=parent, channels=[CHANNEL]
-        )
-        entry = result[CHANNEL]
-
-        assert entry.get("seed") == [10, 20], (
-            "the walk stopped at the empty blob instead of reaching the real "
-            f"value at step 0; got {entry.get('seed', '<missing>')}"
-        )
-        assert [w[2] for w in entry["writes"]] == ["w0", "w1", "w2"]
-
-
-@pytest.mark.asyncio
-async def test_inline_primitive_seed_is_found() -> None:
-    """`put` keeps `None`, `str`, `int`, `float` and `bool` in the checkpoint's
-    own `channel_values` with no blob row, so a blob probe alone cannot see
-    them. Stage 1 reads the inline value too and uses it when there is no blob.
-    """
-    async with AsyncPostgresSaver.from_conn_string(DEFAULT_URI) as saver:
-        await saver.setup()
-        for seed_value in (42, "x", 3.5, None):
-            _, head = await _build_chain(saver, seed_value)
-            entry = (
-                await saver.aget_delta_channel_history(config=head, channels=[CHANNEL])
-            )[CHANNEL]
-            if seed_value is None:
-                # A JSON null is indistinguishable from "no value stored", so
-                # the walk keeps going; replay from empty is the correct result.
-                assert "seed" not in entry
-            else:
-                assert entry.get("seed") == seed_value, (
-                    f"inline {type(seed_value).__name__} seed not found: "
-                    f"{entry.get('seed', '<missing>')!r}"
-                )
-                assert [w[2] for w in entry["writes"]] == ["w1", "w2"]
-
-
-@pytest.mark.asyncio
-async def test_inline_true_is_not_read_as_a_snapshot_marker() -> None:
-    """`put` inlines a literal `true` in `channel_values` as the marker for a
-    `_DeltaSnapshot`, which is also what a genuine `bool` channel holding
-    `True` looks like. A blob exists only in the snapshot case, so preferring
-    the blob keeps the two apart.
-    """
-    async with AsyncPostgresSaver.from_conn_string(DEFAULT_URI) as saver:
-        await saver.setup()
-
-        _, head = await _build_chain(saver, True)
-        entry = (
-            await saver.aget_delta_channel_history(config=head, channels=[CHANNEL])
-        )[CHANNEL]
-        assert entry.get("seed") is True, (
-            f"a real inline True must survive, got {entry.get('seed', '<missing>')!r}"
-        )
-
-        _, snap_head = await _build_chain(saver, _DeltaSnapshot(True))
-        snap_entry = (
-            await saver.aget_delta_channel_history(config=snap_head, channels=[CHANNEL])
-        )[CHANNEL]
-        seed = snap_entry.get("seed")
-        assert isinstance(seed, _DeltaSnapshot), (
-            f"the marker must resolve to the blob, not inline true; got {seed!r}"
-        )
-        assert seed.value is True

libs/checkpoint-postgres/tests/test_store.py

@@ -20,10 +20,6 @@ from langgraph.store.base import (
 from psycopg import Connection
 
 from langgraph.store.postgres import PostgresStore
-from langgraph.store.postgres.base import (
-    _escape_like_literal,
-    _namespace_match_pattern,
-)
 from tests.conftest import (
     DEFAULT_URI,
     VECTOR_TYPES,
@@ -330,127 +326,6 @@ def test_list_namespaces(store) -> None:
         store.delete(namespace, "dummy")
 
 
-def test_escape_like_literal() -> None:
-    assert _escape_like_literal("users.alice") == "users.alice"
-    assert _escape_like_literal("user_1") == r"user\_1"
-    assert _escape_like_literal("100%") == r"100\%"
-    assert _escape_like_literal("a\\b") == "a\\\\b"
-    assert _escape_like_literal("") == ""
-
-
-def test_namespace_match_pattern() -> None:
-    assert _namespace_match_pattern(("foo",), "prefix") == r"^foo(\.|\Z)"
-    assert _namespace_match_pattern(("uid", "users"), "prefix") == r"^uid\.users(\.|\Z)"
-    assert (
-        _namespace_match_pattern(("uid", "*", "alice"), "prefix")
-        == r"^uid\.[^.]+\.alice(\.|\Z)"
-    )
-    assert _namespace_match_pattern(("alice",), "suffix") == r"(^|\.)alice\Z"
-
-    # Regex metacharacters in a label are quoted, not interpreted.
-    pattern = _namespace_match_pattern(("a.b+c",), "prefix")
-    assert re.match(pattern, "a.b+c.child")
-    assert not re.match(pattern, "axbbbc")
-
-
-def test_search_namespace_segment_boundary(store) -> None:
-    """Prefix scoping must stop at namespace segment boundaries.
-
-    Namespaces are stored dot-joined, so matching the raw text also returns
-    siblings sharing leading characters. Callers isolate tenants by namespace,
-    so prefix-shaped ids (1 vs 12) would cross-read.
-    """
-    for namespace in [
-        ("foo",),
-        ("foo", "child"),
-        ("foo", "child", "deep"),
-        ("foobar",),
-        ("foobar", "baz"),
-        ("foo2",),
-    ]:
-        store.put(namespace, "k", {"v": 1})
-
-    def _namespaces(prefix: tuple[str, ...]) -> set[tuple[str, ...]]:
-        return {item.namespace for item in store.search(prefix, limit=100)}
-
-    assert _namespaces(("foo",)) == {
-        ("foo",),
-        ("foo", "child"),
-        ("foo", "child", "deep"),
-    }
-    # The sibling scope is independent, not merely narrower.
-    assert _namespaces(("foobar",)) == {("foobar",), ("foobar", "baz")}
-    assert _namespaces(("foo", "child")) == {("foo", "child"), ("foo", "child", "deep")}
-    assert _namespaces(("foo2",)) == {("foo2",)}
-    assert _namespaces(("fo",)) == set()
-
-
-def test_search_empty_prefix_is_unconstrained(store) -> None:
-    """An empty prefix constrains nothing and must return every namespace."""
-    for namespace in [("a",), ("b", "c"), ("d", "e", "f")]:
-        store.put(namespace, "k", {"v": 1})
-
-    assert {item.namespace for item in store.search((), limit=100)} == {
-        ("a",),
-        ("b", "c"),
-        ("d", "e", "f"),
-    }
-
-
-def test_search_namespace_like_metacharacters(store) -> None:
-    """`_` and `%` are legal namespace labels, not LIKE wildcards."""
-    for namespace in [
-        ("user_1",),
-        ("user_1", "child"),
-        ("userX1",),
-        ("a%b",),
-        ("axxb",),
-    ]:
-        store.put(namespace, "k", {"v": 1})
-
-    def _namespaces(prefix: tuple[str, ...]) -> set[tuple[str, ...]]:
-        return {item.namespace for item in store.search(prefix, limit=100)}
-
-    # Also asserts the namespace still matches itself, which catches escaping
-    # the equality arm by mistake.
-    assert _namespaces(("user_1",)) == {("user_1",), ("user_1", "child")}
-    assert _namespaces(("a%b",)) == {("a%b",)}
-
-
-def test_list_namespaces_segment_boundary(store) -> None:
-    for namespace in [
-        ("foo",),
-        ("foo", "child"),
-        ("foobar",),
-        ("foobar", "baz"),
-        ("uid", "users", "alice"),
-        ("uid", "users", "malice"),
-        ("uid", "a", "b", "alice"),
-    ]:
-        store.put(namespace, "k", {"v": 1})
-
-    assert set(store.list_namespaces(prefix=["foo"], limit=100)) == {
-        ("foo",),
-        ("foo", "child"),
-    }
-    # Suffix must align to a segment: "malice" does not end with the "alice"
-    # segment.
-    assert set(store.list_namespaces(suffix=["alice"], limit=100)) == {
-        ("uid", "users", "alice"),
-        ("uid", "a", "b", "alice"),
-    }
-    # "*" spans exactly one segment.
-    assert set(store.list_namespaces(prefix=["uid", "*", "alice"], limit=100)) == {
-        ("uid", "users", "alice"),
-    }
-    # Prefix matching stays open-ended across depth.
-    assert set(store.list_namespaces(prefix=["uid"], limit=100)) == {
-        ("uid", "users", "alice"),
-        ("uid", "users", "malice"),
-        ("uid", "a", "b", "alice"),
-    }
-
-
 def test_search(store) -> None:
     # Create test data
     test_data = [
@@ -988,133 +863,6 @@ def test_store_ttl(store):
     assert len(res) == 0
 
 
-def _expire_now(store: PostgresStore, ns: tuple[str, ...], key: str) -> None:
-    """Backdate a row's expires_at into the past without deleting it (unswept)."""
-    with store._cursor() as cur:
-        cur.execute(
-            "UPDATE store SET expires_at = NOW() - INTERVAL '1 minute' "
-            "WHERE prefix = %s AND key = %s",
-            (".".join(ns), key),
-        )
-
-
-def _row_exists(store: PostgresStore, ns: tuple[str, ...], key: str) -> bool:
-    with store._cursor() as cur:
-        cur.execute(
-            "SELECT COUNT(*) AS n FROM store WHERE prefix = %s AND key = %s",
-            (".".join(ns), key),
-        )
-        return cur.fetchone()["n"] == 1
-
-
-def _stored_expires_at(store: PostgresStore, ns: tuple[str, ...], key: str):
-    with store._cursor() as cur:
-        cur.execute(
-            "SELECT expires_at FROM store WHERE prefix = %s AND key = %s",
-            (".".join(ns), key),
-        )
-        return cur.fetchone()["expires_at"]
-
-
-def test_omit_expired_filters_read_paths(store: PostgresStore) -> None:
-    store.stop_ttl_sweeper()  # deterministic: no background deletion
-    store.ttl_config["omit_expired"] = True
-
-    expired_ns = ("omit", "expired")
-    control_ns = ("omit", "control")
-    store.put(expired_ns, "e", {"data": "gone"}, ttl=TTL_MINUTES)
-    store.put(control_ns, "c", {"data": "keep"}, ttl=None)
-    _expire_now(store, expired_ns, "e")
-
-    # The row is expired but physically still present (unswept).
-    assert _row_exists(store, expired_ns, "e")
-
-    # get omits it; the never-expiring control is still returned.
-    assert store.get(expired_ns, "e") is None
-    assert store.get(control_ns, "c") is not None
-
-    # search omits it but returns the control.
-    assert store.search(expired_ns) == []
-    assert [i.key for i in store.search(control_ns)] == ["c"]
-
-    # list_namespaces drops the expired-only namespace, keeps the control.
-    namespaces = store.list_namespaces(prefix=("omit",))
-    assert expired_ns not in namespaces
-    assert control_ns in namespaces
-
-
-@pytest.mark.parametrize("omit", [None, False], ids=["default", "explicit-false"])
-def test_omit_expired_disabled_preserves_expired_rows(
-    store: PostgresStore, omit
-) -> None:
-    store.stop_ttl_sweeper()
-    if omit is not None:
-        store.ttl_config["omit_expired"] = omit
-
-    ns = ("keep",)
-    store.put(ns, "k", {"data": "still-here"}, ttl=TTL_MINUTES)
-    _expire_now(store, ns, "k")
-
-    assert store.get(ns, "k", refresh_ttl=False) is not None
-    assert [i.key for i in store.search(ns, refresh_ttl=False)] == ["k"]
-    assert ns in store.list_namespaces(prefix=("keep",))
-
-
-def test_omit_expired_refresh_ttl_only_refreshes_live_rows(
-    store: PostgresStore,
-) -> None:
-    store.stop_ttl_sweeper()
-    store.ttl_config["omit_expired"] = True
-
-    ns = ("refresh",)
-    store.put(ns, "expired", {"n": 0}, ttl=TTL_MINUTES)
-    store.put(ns, "live_get", {"n": 1}, ttl=TTL_MINUTES)
-    store.put(ns, "live_search", {"n": 2}, ttl=TTL_MINUTES)
-    _expire_now(store, ns, "expired")
-
-    expired_before = _stored_expires_at(store, ns, "expired")
-    get_before = _stored_expires_at(store, ns, "live_get")
-    search_before = _stored_expires_at(store, ns, "live_search")
-
-    # refresh_ttl=True must NOT resurrect the expired row (via get or search)...
-    assert store.get(ns, "expired", refresh_ttl=True) is None
-    assert "expired" not in [i.key for i in store.search(ns, refresh_ttl=True)]
-    assert _stored_expires_at(store, ns, "expired") == expired_before
-
-    # ...but must still extend the live rows that were read.
-    assert store.get(ns, "live_get", refresh_ttl=True) is not None
-    assert _stored_expires_at(store, ns, "live_get") > get_before
-    assert _stored_expires_at(store, ns, "live_search") > search_before
-
-
-def test_omit_expired_search_pagination(store: PostgresStore) -> None:
-    store.stop_ttl_sweeper()
-    store.ttl_config["omit_expired"] = True
-
-    ns = ("page",)
-    for k in ("a", "b", "c"):
-        store.put(ns, k, {"k": k}, ttl=TTL_MINUTES)
-    store.put(ns, "expired", {"k": "x"}, ttl=TTL_MINUTES)
-    _expire_now(store, ns, "expired")
-
-    seconds_ago = {"a": 1, "expired": 2, "b": 3, "c": 4}
-    # updated_at DESC orders these a, expired, b, c, so the expired row sits inside
-    # the first limit=2 window. Correct (pre-LIMIT) filtering yields live pages
-    # [a, b] then [c]; post-LIMIT filtering would underfill page 1 to just [a].
-    with store._cursor() as cur:
-        for key, secs in seconds_ago.items():
-            cur.execute(
-                "UPDATE store SET updated_at = NOW() - (%s * INTERVAL '1 second') "
-                "WHERE prefix = %s AND key = %s",
-                (secs, ".".join(ns), key),
-            )
-
-    page1 = store.search(ns, limit=2, offset=0)
-    page2 = store.search(ns, limit=2, offset=2)
-    assert [i.key for i in page1] == ["a", "b"]
-    assert [i.key for i in page2] == ["c"]
-
-
 @pytest.mark.parametrize(
     "vector_type,distance_type",
     [
@@ -1151,16 +899,3 @@ def test_non_ascii(
         assert result3[0].key == "3"
         assert result4[0].key == "4"
         assert result5[0].key == "5"
-
-
-def test_namespace_labels_with_trailing_newline(store) -> None:
-    """Labels may contain newlines, and must not match a differently-named label."""
-    store.put(("users", "alice"), "k", {"v": 1})
-    store.put(("users", "alice\n"), "k", {"v": 2})
-
-    assert set(store.list_namespaces(suffix=["alice"], limit=100)) == {
-        ("users", "alice"),
-    }
-    assert set(store.list_namespaces(prefix=["users", "alice"], limit=100)) == {
-        ("users", "alice"),
-    }

libs/checkpoint-sqlite/langgraph/checkpoint/sqlite/__init__.py

@@ -77,7 +77,7 @@ class SqliteSaver(BaseCheckpointSaver[str]):
         >>> result = graph.invoke(3, config)
         >>> graph.get_state(config)
         StateSnapshot(values=4, next=(), config={'configurable': {'thread_id': '1', 'checkpoint_ns': '', 'checkpoint_id': '0c62ca34-ac19-445d-bbb0-5b4984975b2a'}}, parent_config=None)
-    """
+    """  # noqa
 
     conn: sqlite3.Connection
     is_setup: bool
@@ -222,7 +222,7 @@ class SqliteSaver(BaseCheckpointSaver[str]):
             >>> checkpoint_tuple = memory.get_tuple(config)
             >>> print(checkpoint_tuple)
             CheckpointTuple(...)
-        """
+        """  # noqa
         checkpoint_ns = config["configurable"].get("checkpoint_ns", "")
         with self.cursor(transaction=False) as cur:
             # find the latest checkpoint for the thread_id

libs/checkpoint-sqlite/langgraph/checkpoint/sqlite/aio.py

@@ -212,7 +212,7 @@ class AsyncSqliteSaver(BaseCheckpointSaver[str]):
         while True:
             try:
                 yield asyncio.run_coroutine_threadsafe(
-                    anext(aiter_),  # type: ignore[arg-type]
+                    anext(aiter_),  # type: ignore[arg-type]  # noqa: F821
                     self.loop,
                 ).result()
             except StopAsyncIteration:

libs/checkpoint-sqlite/langgraph/store/sqlite/aio.py

@@ -24,13 +24,11 @@ from langgraph.store.base.batch import AsyncBatchedBaseStore
 
 from langgraph.store.sqlite.base import (
     _PLACEHOLDER,
-    NS_MATCH_FUNCTION,
     BaseSqliteStore,
     SqliteIndexConfig,
     _decode_ns_text,
     _ensure_index_config,
     _group_ops,
-    _namespace_match,
     _row_to_item,
     _row_to_search_item,
 )
@@ -152,13 +150,6 @@ class AsyncSqliteStore(AsyncBatchedBaseStore, BaseSqliteStore):
             if self.is_setup:
                 return
 
-            # list_namespaces needs segment-aware matching, which SQLite cannot
-            # express in LIKE or GLOB. Registered here rather than in __init__
-            # because aiosqlite's create_function is a coroutine.
-            await self.conn.create_function(
-                NS_MATCH_FUNCTION, 2, _namespace_match, deterministic=True
-            )
-
             # Create migrations table if it doesn't exist
             await self.conn.execute(
                 """

libs/checkpoint-sqlite/langgraph/store/sqlite/base.py

@@ -7,7 +7,7 @@ import re
 import sqlite3
 import threading
 from collections import defaultdict
-from collections.abc import Callable, Iterable, Iterator, Mapping, Sequence
+from collections.abc import Callable, Iterable, Iterator, Sequence
 from contextlib import contextmanager
 from typing import Any, Literal, NamedTuple, cast
 
@@ -93,74 +93,12 @@ class SqliteIndexConfig(IndexConfig):
     pass
 
 
-NS_MATCH_FUNCTION = "_langgraph_namespace_match"
-"""SQLite user function backing segment-aware namespace matching.
-
-Registered under a private name rather than overriding `REGEXP`, so a caller's
-own `REGEXP` is left untouched.
-"""
-
-
-def _namespace_match(prefix: str | None, pattern: str) -> int:
-    """Backing implementation of `NS_MATCH_FUNCTION`."""
-    if prefix is None:
-        return 0
-    return 1 if re.search(pattern, prefix) else 0
-
-
-def _escape_glob_literal(text: str) -> str:
-    """Escape GLOB metacharacters so `text` is matched literally.
-
-    GLOB has no `ESCAPE` clause, so metacharacters are wrapped in a character
-    class instead. `]` is literal outside a class and needs no escaping.
-    """
-    return text.replace("[", "[[]").replace("*", "[*]").replace("?", "[?]")
-
-
-def _namespace_prefix_condition(
-    namespace_prefix: tuple[str, ...], column: str = "prefix"
-) -> tuple[str, tuple[str, ...]]:
-    """Build the SQL scoping a search to a namespace and its descendants.
-
-    Matches the namespace exactly or requires the `.` separator before any
-    remainder, so a prefix of `("foo",)` does not also match `("foobar",)`.
-
-    Uses GLOB rather than LIKE because SQLite's LIKE is case-insensitive for
-    ASCII, which would match `("FOO",)` for a prefix of `("foo",)` even though
-    `get`/`put`/`delete` compare with `=` and treat those as distinct.
-
-    An empty prefix is unconstrained and matches every namespace.
-    """
-    if not namespace_prefix:
-        return "TRUE", ()
-    path = _namespace_to_text(namespace_prefix)
-    condition = f"({column} = ? OR {column} GLOB ?)"
-    return condition, (path, f"{_escape_glob_literal(path)}.*")
-
-
-def _namespace_match_pattern(path: tuple[str, ...], match_type: str) -> str:
-    """Build a regex matching the dot-joined prefix on whole namespace segments.
-
-    Needed because neither LIKE nor GLOB can express "any character except the
-    separator": GLOB has character classes but no quantifier, so `[^.]*` still
-    crosses `.`. Matches how `InMemoryStore` compares namespaces element-wise.
-
-    `*` matches exactly one segment. Prefix matches stay open-ended but must end
-    on a separator; suffix matches anchor at the end and begin on one.
-
-    Examples:
-        prefix ("uid", "*", "alice") -> ^uid\\.[^.]+\\.alice(\\.|\\Z)
-        suffix ("alice",)            -> (^|\\.)alice\\Z
-    """
-    segments = ("[^.]+" if part == "*" else re.escape(part) for part in path)
-    body = r"\.".join(segments)
-    if match_type == "suffix":
-        return rf"(^|\.){body}\Z"
-    return rf"^{body}(\.|\Z)"
-
-
-def _namespace_to_text(namespace: tuple[str, ...]) -> str:
+def _namespace_to_text(
+    namespace: tuple[str, ...], handle_wildcards: bool = False
+) -> str:
     """Convert namespace tuple to text string."""
+    if handle_wildcards:
+        namespace = tuple("%" if val == "*" else val for val in namespace)
     return ".".join(namespace)
 
 
@@ -387,7 +325,7 @@ class BaseSqliteStore:
                     [
                         _namespace_to_text(op.namespace),
                         op.key,
-                        orjson.dumps(dict(cast(Mapping[str, Any], op.value))),
+                        orjson.dumps(cast(dict, op.value)),
                         expires_at,
                         op.ttl,
                     ]
@@ -523,11 +461,8 @@ class BaseSqliteStore:
                     else " AND " + " AND ".join(filter_conditions)
                 )
                 if op.namespace_prefix:
-                    ns_condition, ns_args_tuple = _namespace_prefix_condition(
-                        op.namespace_prefix, column="s.prefix"
-                    )
-                    prefix_filter_str = f"WHERE {ns_condition} {filter_str} "
-                    ns_args: Sequence = ns_args_tuple
+                    prefix_filter_str = f"WHERE s.prefix LIKE ? {filter_str} "
+                    ns_args: Sequence = (f"{_namespace_to_text(op.namespace_prefix)}%",)
                 else:
                     ns_args = ()
                     if filter_str:
@@ -568,15 +503,12 @@ class BaseSqliteStore:
                 ]
             # Regular search branch (no vector search)
             else:
-                ns_condition, ns_args_tuple = _namespace_prefix_condition(
-                    op.namespace_prefix
-                )
-                base_query = f"""
+                base_query = """
                     SELECT prefix, key, value, created_at, updated_at, expires_at, ttl_minutes, NULL as score
                     FROM store
-                    WHERE {ns_condition}
+                    WHERE prefix LIKE ?
                 """
-                params = list(ns_args_tuple)
+                params = [f"{_namespace_to_text(op.namespace_prefix)}%"]
 
                 if filter_conditions:
                     params.extend(filter_params)
@@ -617,28 +549,16 @@ class BaseSqliteStore:
 
             if op.match_conditions:
                 for cond in op.match_conditions:
-                    if cond.match_type in ("prefix", "suffix"):
-                        if not cond.path:
-                            # An empty path constrains nothing; skipping keeps it a
-                            # no-op rather than emitting a pattern that matches no
-                            # namespace at all.
-                            continue
-                        if cond.match_type == "prefix" and "*" not in cond.path:
-                            # Equivalent to the anchored pattern, but SQLite can
-                            # satisfy `=` and a trailing-wildcard GLOB from
-                            # store_prefix_idx. The user function is opaque to the
-                            # planner, so it would scan every row and call back
-                            # into Python for each one.
-                            condition, args = _namespace_prefix_condition(
-                                tuple(cond.path)
-                            )
-                            where_clauses.append(condition)
-                            params.extend(args)
-                        else:
-                            where_clauses.append(f"{NS_MATCH_FUNCTION}(prefix, ?) = 1")
-                            params.append(
-                                _namespace_match_pattern(cond.path, cond.match_type)
-                            )
+                    if cond.match_type == "prefix":
+                        where_clauses.append("prefix LIKE ?")
+                        params.append(
+                            f"{_namespace_to_text(cond.path, handle_wildcards=True)}%"
+                        )
+                    elif cond.match_type == "suffix":
+                        where_clauses.append("prefix LIKE ?")
+                        params.append(
+                            f"%{_namespace_to_text(cond.path, handle_wildcards=True)}"
+                        )
                     else:
                         logger.warning(
                             "Unknown match_type in list_namespaces: %s", cond.match_type
@@ -865,9 +785,6 @@ class SqliteStore(BaseSqliteStore, BaseStore):
         super().__init__()
         self._deserializer = deserializer
         self.conn = conn
-        # Registered here rather than in from_conn_string so a caller-supplied
-        # connection also gets it.
-        conn.create_function(NS_MATCH_FUNCTION, 2, _namespace_match, deterministic=True)
         self.lock = threading.Lock()
         self.is_setup = False
         self.index_config = index

libs/checkpoint-sqlite/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "langgraph-checkpoint-sqlite"
-version = "3.1.1"
+version = "3.1.0"
 description = "Library with a SQLite implementation of LangGraph checkpoint saver."
 authors = []
 requires-python = ">=3.10"
@@ -30,7 +30,6 @@ test = [
   "pytest-mock",
   "pytest-watcher",
   "langgraph-checkpoint",
-  "langgraph-checkpoint-conformance",
   "pytest-retry>=1.7.0",
 ]
 lint = [
@@ -48,7 +47,6 @@ default-groups = ['dev']
 
 [tool.uv.sources]
 langgraph-checkpoint = { path = "../checkpoint", editable = true }
-langgraph-checkpoint-conformance = { path = "../checkpoint-conformance", editable = true }
 
 [tool.hatch.build.targets.wheel]
 include = ["langgraph"]
@@ -64,8 +62,6 @@ lint.select = [
   "UP", # pyupgrade
   "B",  # flake8-bugbear
   "I",  # isort
-  "PLC0415",  # import-outside-top-level
-  "RUF100",  # unused noqa directive
   "UP", # pyupgrade
 ]
 lint.ignore = ["E501", "B008"]

libs/checkpoint-sqlite/tests/test_async_store.py

@@ -716,32 +716,3 @@ async def test_search_items(
         for ns in test_namespaces:
             key = f"item_{ns[-1]}"
             await store.adelete(ns, key)
-
-
-async def test_async_namespace_segment_boundary(store: AsyncSqliteStore) -> None:
-    """Segment-aware scoping on the async path.
-
-    Also covers that the namespace-match SQLite function is registered on the
-    async connection -- aiosqlite's create_function is a coroutine, so it is
-    registered in setup() rather than __init__.
-    """
-    for namespace in [
-        ("foo",),
-        ("foo", "child"),
-        ("foobar",),
-        ("uid", "users", "alice"),
-        ("uid", "users", "malice"),
-        ("user_1",),
-        ("userX1",),
-    ]:
-        await store.aput(namespace, "k", {"v": 1})
-
-    found = {item.namespace for item in await store.asearch(("foo",), limit=100)}
-    assert found == {("foo",), ("foo", "child")}
-
-    found = {item.namespace for item in await store.asearch(("user_1",), limit=100)}
-    assert found == {("user_1",)}
-
-    assert set(await store.alist_namespaces(suffix=["alice"], limit=100)) == {
-        ("uid", "users", "alice"),
-    }

libs/checkpoint-sqlite/tests/test_conformance_delta.py

@@ -3,14 +3,21 @@
 from __future__ import annotations
 
 import pytest
-from langgraph.checkpoint.conformance import validate
-from langgraph.checkpoint.conformance.initializer import checkpointer_test
 
-from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
+pytest.importorskip(
+    "langgraph.checkpoint.conformance",
+    reason="langgraph-checkpoint-conformance not installed",
+)
+pytest.importorskip("aiosqlite", reason="aiosqlite not installed")
 
 
 @pytest.mark.asyncio
 async def test_delta_channel_conformance():
+    from langgraph.checkpoint.conformance import validate
+    from langgraph.checkpoint.conformance.initializer import checkpointer_test
+
+    from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
+
     @checkpointer_test(name="AsyncSqliteSaver")
     async def sqlite_saver():
         async with AsyncSqliteSaver.from_conn_string(":memory:") as saver:

libs/checkpoint-sqlite/tests/test_delta_channel_migration.py

@@ -29,13 +29,13 @@ pytest.importorskip("langgraph.channels.delta", reason="langgraph core not insta
 pytest.importorskip("langgraph.channels.binop", reason="langgraph core not installed")
 pytest.importorskip("langgraph.graph", reason="langgraph core not installed")
 
-from langgraph.channels.binop import BinaryOperatorAggregate  # type: ignore[import-untyped]  # noqa: I001
-from langgraph.channels.delta import DeltaChannel  # type: ignore[import-untyped]
-from langgraph.graph import END, START, StateGraph  # type: ignore[import-untyped]
-from typing_extensions import TypedDict
+from langgraph.channels.binop import BinaryOperatorAggregate  # type: ignore[import-untyped]  # noqa: E402,I001
+from langgraph.channels.delta import DeltaChannel  # type: ignore[import-untyped]  # noqa: E402
+from langgraph.graph import END, START, StateGraph  # type: ignore[import-untyped]  # noqa: E402
+from typing_extensions import TypedDict  # noqa: E402
 
-from langgraph.checkpoint.sqlite import SqliteSaver
-from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
+from langgraph.checkpoint.sqlite import SqliteSaver  # noqa: E402
+from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver  # noqa: E402
 
 pytestmark = pytest.mark.anyio
 

libs/checkpoint-sqlite/tests/test_get_delta_channel_history.py

@@ -32,13 +32,13 @@ from langchain_core.runnables import RunnableConfig
 pytest.importorskip("langgraph.channels.delta", reason="langgraph core not installed")
 pytest.importorskip("langgraph.graph", reason="langgraph core not installed")
 
-from langgraph.channels.delta import DeltaChannel  # type: ignore[import-untyped]  # noqa: I001
-from langgraph.checkpoint.serde.types import _DeltaSnapshot
-from langgraph.graph import END, START, StateGraph  # type: ignore[import-untyped]
-from typing_extensions import TypedDict
+from langgraph.channels.delta import DeltaChannel  # type: ignore[import-untyped]  # noqa: E402,I001
+from langgraph.checkpoint.serde.types import _DeltaSnapshot  # noqa: E402
+from langgraph.graph import END, START, StateGraph  # type: ignore[import-untyped]  # noqa: E402
+from typing_extensions import TypedDict  # noqa: E402
 
-from langgraph.checkpoint.sqlite import SqliteSaver
-from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
+from langgraph.checkpoint.sqlite import SqliteSaver  # noqa: E402
+from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver  # noqa: E402
 
 pytestmark = pytest.mark.anyio
 

libs/checkpoint-sqlite/tests/test_store.py

@@ -1,11 +1,7 @@
-import math
 import os
-import random
 import re
 import tempfile
-import time
 import uuid
-from collections import Counter, defaultdict
 from collections.abc import Generator, Iterable
 from contextlib import contextmanager
 from typing import Any, Literal, cast
@@ -22,13 +18,7 @@ from langgraph.store.base import (
 )
 
 from langgraph.store.sqlite import SqliteStore
-from langgraph.store.sqlite.base import (
-    NS_MATCH_FUNCTION,
-    BaseSqliteStore,
-    SqliteIndexConfig,
-    _escape_glob_literal,
-    _namespace_match_pattern,
-)
+from langgraph.store.sqlite.base import SqliteIndexConfig
 
 
 # Local embeddings implementation for testing vector search
@@ -37,6 +27,10 @@ class CharacterEmbeddings(Embeddings):
 
     def __init__(self, dims: int = 50, seed: int = 42):
         """Initialize with embedding dimensions and random seed."""
+        import math
+        import random
+        from collections import defaultdict
+
         self._rng = random.Random(seed)
         self.dims = dims
         # Create projection vector for each character lazily
@@ -48,6 +42,9 @@ class CharacterEmbeddings(Embeddings):
 
     def _embed_one(self, text: str) -> list[float]:
         """Embed a single text."""
+        import math
+        from collections import Counter
+
         counts = Counter(text)
         total = sum(counts.values())
 
@@ -335,6 +332,8 @@ class TestSqliteStore:
 
             # Test update
             # Small delay to ensure the updated timestamp is different
+            import time
+
             time.sleep(0.01)
 
             updated_value = {"title": "Updated Document", "content": "Hello, Updated!"}
@@ -1230,208 +1229,3 @@ def test_non_ascii(
         assert result3[0].key == "3"
         assert result4[0].key == "4"
         assert result5[0].key == "5"
-
-
-def test_escape_glob_literal() -> None:
-    assert _escape_glob_literal("users.alice") == "users.alice"
-    # "_" and "%" are LIKE wildcards but literal in GLOB, so they are left alone.
-    assert _escape_glob_literal("user_1") == "user_1"
-    assert _escape_glob_literal("100%") == "100%"
-    assert _escape_glob_literal("a*b") == "a[*]b"
-    assert _escape_glob_literal("a?b") == "a[?]b"
-    assert _escape_glob_literal("a[b") == "a[[]b"
-
-
-def test_namespace_match_pattern() -> None:
-    assert _namespace_match_pattern(("foo",), "prefix") == r"^foo(\.|\Z)"
-    assert (
-        _namespace_match_pattern(("uid", "*", "alice"), "prefix")
-        == r"^uid\.[^.]+\.alice(\.|\Z)"
-    )
-    assert _namespace_match_pattern(("alice",), "suffix") == r"(^|\.)alice\Z"
-
-
-def test_search_namespace_segment_boundary(store: SqliteStore) -> None:
-    """Prefix scoping must stop at namespace segment boundaries.
-
-    Namespaces are stored dot-joined, so matching the raw text also returns
-    siblings sharing leading characters.
-    """
-    for namespace in [
-        ("foo",),
-        ("foo", "child"),
-        ("foo", "child", "deep"),
-        ("foobar",),
-        ("foobar", "baz"),
-        ("foo2",),
-    ]:
-        store.put(namespace, "k", {"v": 1})
-
-    def _namespaces(prefix: tuple[str, ...]) -> set[tuple[str, ...]]:
-        return {item.namespace for item in store.search(prefix, limit=100)}
-
-    assert _namespaces(("foo",)) == {
-        ("foo",),
-        ("foo", "child"),
-        ("foo", "child", "deep"),
-    }
-    # The sibling scope is independent, not merely narrower.
-    assert _namespaces(("foobar",)) == {("foobar",), ("foobar", "baz")}
-    assert _namespaces(("foo2",)) == {("foo2",)}
-    assert _namespaces(("fo",)) == set()
-
-
-def test_search_namespace_wildcard_chars_are_literal(store: SqliteStore) -> None:
-    """LIKE and GLOB metacharacters in labels must be matched literally."""
-    for namespace in [
-        ("user_1",),
-        ("user_1", "child"),
-        ("userX1",),
-        ("a%b",),
-        ("axxb",),
-        ("star*",),
-        ("starX",),
-    ]:
-        store.put(namespace, "k", {"v": 1})
-
-    def _namespaces(prefix: tuple[str, ...]) -> set[tuple[str, ...]]:
-        return {item.namespace for item in store.search(prefix, limit=100)}
-
-    # Also asserts each namespace still matches itself, which catches escaping
-    # the equality arm by mistake.
-    assert _namespaces(("user_1",)) == {("user_1",), ("user_1", "child")}
-    assert _namespaces(("a%b",)) == {("a%b",)}
-    assert _namespaces(("star*",)) == {("star*",)}
-
-
-def test_search_namespace_is_case_sensitive(store: SqliteStore) -> None:
-    """Search must agree with get/put, which compare namespaces with `=`.
-
-    SQLite's LIKE is case-insensitive for ASCII, so matching with it conflated
-    namespaces that every other operation treats as distinct.
-    """
-    store.put(("Foo",), "k", {"v": "upper"})
-    store.put(("foo",), "k", {"v": "lower"})
-
-    assert {item.namespace for item in store.search(("foo",), limit=100)} == {("foo",)}
-    assert {item.namespace for item in store.search(("Foo",), limit=100)} == {("Foo",)}
-
-
-def test_list_namespaces_segment_boundary(store: SqliteStore) -> None:
-    for namespace in [
-        ("foo",),
-        ("foo", "child"),
-        ("foobar",),
-        ("foobar", "baz"),
-        ("uid", "users", "alice"),
-        ("uid", "users", "malice"),
-        ("uid", "a", "b", "alice"),
-    ]:
-        store.put(namespace, "k", {"v": 1})
-
-    assert set(store.list_namespaces(prefix=["foo"], limit=100)) == {
-        ("foo",),
-        ("foo", "child"),
-    }
-    # Suffix must align to a segment: "malice" does not end with the "alice"
-    # segment.
-    assert set(store.list_namespaces(suffix=["alice"], limit=100)) == {
-        ("uid", "users", "alice"),
-        ("uid", "a", "b", "alice"),
-    }
-    # "*" spans exactly one segment.
-    assert set(store.list_namespaces(prefix=["uid", "*", "alice"], limit=100)) == {
-        ("uid", "users", "alice"),
-    }
-    # Prefix matching stays open-ended across depth.
-    assert set(store.list_namespaces(prefix=["uid"], limit=100)) == {
-        ("uid", "users", "alice"),
-        ("uid", "users", "malice"),
-        ("uid", "a", "b", "alice"),
-    }
-
-
-def test_search_empty_prefix_is_unconstrained(store: SqliteStore) -> None:
-    """An empty prefix constrains nothing and must return every namespace."""
-    for namespace in [("a",), ("b", "c"), ("d", "e", "f")]:
-        store.put(namespace, "k", {"v": 1})
-
-    assert {item.namespace for item in store.search((), limit=100)} == {
-        ("a",),
-        ("b", "c"),
-        ("d", "e", "f"),
-    }
-
-
-def test_namespace_labels_with_trailing_newline(store: SqliteStore) -> None:
-    """Labels may contain newlines, and must not match a differently-named label.
-
-    Python's `$` also matches just before a trailing newline, so the patterns use
-    `\\Z` to anchor at the true end of the string.
-    """
-    store.put(("users", "alice"), "k", {"v": 1})
-    store.put(("users", "alice\n"), "k", {"v": 2})
-
-    assert set(store.list_namespaces(suffix=["alice"], limit=100)) == {
-        ("users", "alice"),
-    }
-    assert set(store.list_namespaces(prefix=["users", "alice"], limit=100)) == {
-        ("users", "alice"),
-    }
-
-
-def test_list_namespaces_prefix_uses_indexable_condition() -> None:
-    """Plain prefixes must use the indexable condition, not the match function.
-
-    A user function is opaque to the query planner, so it scans every row and
-    calls back into Python for each one. Only suffix and wildcard paths, which
-    no SQLite operator can express, need it.
-    """
-    store = BaseSqliteStore()
-
-    def where(match_type: str, path: tuple[str, ...]) -> str:
-        op = ListNamespacesOp(
-            match_conditions=(MatchCondition(match_type=match_type, path=path),),
-            max_depth=None,
-            limit=10,
-            offset=0,
-        )
-        query, _ = store._get_batch_list_namespaces_queries([(0, op)])[0]
-        return " ".join(query.split())
-
-    assert "GLOB" in where("prefix", ("uid", "users"))
-    assert NS_MATCH_FUNCTION not in where("prefix", ("uid", "users"))
-    # A label that merely contains "*" is not the wildcard.
-    assert "GLOB" in where("prefix", ("star*",))
-    # Wildcard and suffix cannot be expressed by GLOB, so they keep the function.
-    assert NS_MATCH_FUNCTION in where("prefix", ("uid", "*", "alice"))
-    assert NS_MATCH_FUNCTION in where("suffix", ("alice",))
-
-
-def test_list_namespaces_metacharacter_labels(store: SqliteStore) -> None:
-    """Metacharacters in labels are literal on both matching paths.
-
-    Plain prefixes take the `= OR GLOB` condition and wildcard/suffix paths take
-    the regex function, so escaping has to hold in two different syntaxes.
-    """
-    pairs = [
-        ("star*", "starX"),
-        ("q?m", "qXm"),
-        ("br[ack]et", "brXacXket"),
-        ("user_1", "userX1"),
-        ("a%b", "axxb"),
-        ("plus+", "plusX"),
-    ]
-    for label, decoy in pairs:
-        store.put((label,), "k", {"v": 1})
-        store.put((decoy,), "k", {"v": 1})
-        store.put((label, "child"), "k", {"v": 1})
-
-    for label, decoy in pairs:
-        found = set(store.list_namespaces(prefix=[label], limit=100))
-        assert found == {(label,), (label, "child")}
-        # The decoy differs only where the metacharacter would have matched.
-        assert (decoy,) not in found
-        assert set(store.list_namespaces(prefix=[label, "child"], limit=100)) == {
-            (label, "child"),
-        }

libs/checkpoint/README.md

@@ -39,12 +39,7 @@ You must pass these when invoking the graph as part of the configurable part of
 
 ```python
 {"configurable": {"thread_id": "1"}}  # valid config
-{
-    "configurable": {
-        "thread_id": "1",
-        "checkpoint_id": "0c62ca34-ac19-445d-bbb0-5b4984975b2a",
-    }
-}  # also valid config
+{"configurable": {"thread_id": "1", "checkpoint_id": "0c62ca34-ac19-445d-bbb0-5b4984975b2a"}}  # also valid config
 ```
 
 ### Serde
@@ -84,12 +79,24 @@ checkpoint = {
     "v": 4,
     "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},
+    "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},
+      "__input__": {},
+      "__start__": {
+        "__start__": 1
+      },
+      "node": {
+        "start:node": 2
+      }
     },
 }
 

libs/checkpoint/langgraph/checkpoint/base/__init__.py

@@ -10,7 +10,6 @@ from typing import (
     NamedTuple,
     TypedDict,
     TypeVar,
-    cast,
 )
 
 from langchain_core.runnables import RunnableConfig
@@ -782,7 +781,7 @@ def get_serializable_checkpoint_metadata(
     """Get checkpoint metadata in a backwards-compatible manner."""
     checkpoint_metadata = get_checkpoint_metadata(config, metadata)
     if "writes" in checkpoint_metadata:
-        cast(dict[str, Any], checkpoint_metadata).pop("writes")
+        checkpoint_metadata.pop("writes")
     return checkpoint_metadata
 
 

libs/checkpoint/langgraph/checkpoint/memory/__init__.py

@@ -148,16 +148,17 @@ class InMemorySaver(
         whose stored blob is non-empty. Other channels keep walking until
         they find their own terminator or hit the root.
 
-        A blob is the value AT its ancestor, prior to the writes stored
-        under that same ancestor (those writes produce its child, which
-        is on the path to the target). This holds for `_DeltaSnapshot`
-        blobs and for pre-delta plain values alike, so the seed
-        ancestor's own writes are always collected. Writes at ancestors
-        older than the seed are subsumed by the seed value and are never
-        reached — the walk terminates there.
+        Pre-delta plain-value blobs subsume their ancestor's pending
+        writes (the value already includes them); `_DeltaSnapshot` blobs
+        do not (snapshot is the value AT that ancestor, prior to its own
+        pending writes that produce the child).
         """
         if not channels:
             return {}
+        # Imported lazily to avoid a hard checkpoint→serde-types coupling at
+        # module import; only this override needs the runtime check.
+        from langgraph.checkpoint.serde.types import _DeltaSnapshot
+
         thread_id = config["configurable"]["thread_id"]
         checkpoint_ns = config["configurable"].get("checkpoint_ns", "")
         checkpoint_id = config["configurable"].get("checkpoint_id", "")
@@ -204,6 +205,11 @@ class InMemorySaver(
             ):
                 if ch not in remaining:
                     continue
+                blob_value = blob_value_by_ch.get(ch)
+                if blob_value is not None and not isinstance(
+                    blob_value, _DeltaSnapshot
+                ):
+                    continue
                 collected_by_ch[ch].append(
                     (tid, ch, self.serde.loads_typed(serialized))
                 )

libs/checkpoint/langgraph/store/base/__init__.py

@@ -12,7 +12,7 @@ Core types:
 from __future__ import annotations
 
 from abc import ABC, abstractmethod
-from collections.abc import Iterable, Mapping
+from collections.abc import Iterable
 from datetime import datetime
 from typing import (
     Any,
@@ -473,10 +473,10 @@ class PutOp(NamedTuple):
         the full path would effectively be `"documents/user123/report1"`
     """
 
-    value: Mapping[str, Any] | None
+    value: dict[str, Any] | None
     """The data to store, or `None` to mark the item for deletion.
 
-    The value must be a mapping with string keys and JSON-serializable values.
+    The value must be a dictionary with string keys and JSON-serializable values.
     Setting this to `None` signals that the item should be deleted.
 
     Example:
@@ -552,14 +552,6 @@ class TTLConfig(TypedDict, total=False):
     This can be overridden per-operation by explicitly setting `refresh_ttl`.
     Defaults to `True` if not configured.
     """
-    omit_expired: bool
-    """Whether to omit expired items from read operations.
-
-    If `True`, and if the store supports this option, expired items will not be
-    returned by `GET` or `SEARCH`, or included in namespace listings, even before
-    a TTL sweep deletes them.
-    Defaults to `False` if not configured.
-    """
     default_ttl: float | None
     """Default TTL (time-to-live) in minutes for new items.
     
@@ -857,7 +849,7 @@ class BaseStore(ABC):
         self,
         namespace: tuple[str, ...],
         key: str,
-        value: Mapping[str, Any],
+        value: dict[str, Any],
         index: Literal[False] | list[str] | None = None,
         *,
         ttl: float | None | NotProvided = NOT_PROVIDED,
@@ -869,7 +861,7 @@ class BaseStore(ABC):
                 Example: `("documents", "user123")`
             key: Unique identifier within the namespace. Together with namespace forms
                 the complete path to the item.
-            value: Mapping containing the item's data. Must contain string keys
+            value: Dictionary containing the item's data. Must contain string keys
                 and JSON-serializable values.
             index: Controls how the item's fields are indexed for search:
 
@@ -1110,7 +1102,7 @@ class BaseStore(ABC):
         self,
         namespace: tuple[str, ...],
         key: str,
-        value: Mapping[str, Any],
+        value: dict[str, Any],
         index: Literal[False] | list[str] | None = None,
         *,
         ttl: float | None | NotProvided = NOT_PROVIDED,
@@ -1122,7 +1114,7 @@ class BaseStore(ABC):
                 Example: `("documents", "user123")`
             key: Unique identifier within the namespace. Together with namespace forms
                 the complete path to the item.
-            value: Mapping containing the item's data. Must contain string keys
+            value: Dictionary containing the item's data. Must contain string keys
                 and JSON-serializable values.
             index: Controls how the item's fields are indexed for search:
 

libs/checkpoint/langgraph/store/base/batch.py

@@ -5,7 +5,7 @@ from __future__ import annotations
 import asyncio
 import functools
 import weakref
-from collections.abc import Callable, Iterable, Mapping
+from collections.abc import Callable, Iterable
 from typing import Any, Literal, TypeVar
 
 from langgraph.store.base import (
@@ -132,7 +132,7 @@ class AsyncBatchedBaseStore(BaseStore):
         self,
         namespace: tuple[str, ...],
         key: str,
-        value: Mapping[str, Any],
+        value: dict[str, Any],
         index: Literal[False] | list[str] | None = None,
         *,
         ttl: float | None | NotProvided = NOT_PROVIDED,
@@ -231,7 +231,7 @@ class AsyncBatchedBaseStore(BaseStore):
         self,
         namespace: tuple[str, ...],
         key: str,
-        value: Mapping[str, Any],
+        value: dict[str, Any],
         index: Literal[False] | list[str] | None = None,
         *,
         ttl: float | None | NotProvided = NOT_PROVIDED,

libs/checkpoint/langgraph/store/base/embed.py

@@ -11,7 +11,7 @@ from __future__ import annotations
 import asyncio
 import functools
 import json
-from collections.abc import Awaitable, Callable, Mapping, Sequence
+from collections.abc import Awaitable, Callable, Sequence
 from typing import Any
 
 from langchain_core.embeddings import Embeddings
@@ -244,9 +244,6 @@ def get_text_at_path(obj: Any, path: str | list[str]) -> list[str]:
         - Multi-field selection: "{field1,field2}"
         - Nested paths in multi-field: "{field1,nested.field2}"
     """
-    if isinstance(obj, Mapping) and not isinstance(obj, dict):
-        obj = dict(obj)
-
     if not path or path == "$":
         return [json.dumps(obj, sort_keys=True, ensure_ascii=False)]
 

libs/checkpoint/langgraph/store/memory/__init__.py

@@ -408,7 +408,7 @@ class InMemoryStore(BaseStore):
                 self._vectors[namespace].pop(key, None)
             else:
                 self._data[namespace][key] = Item(
-                    value=dict(op.value),
+                    value=op.value,
                     key=key,
                     namespace=namespace,
                     created_at=datetime.now(timezone.utc),

libs/checkpoint/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "langgraph-checkpoint"
-version = "4.2.0"
+version = "4.1.1"
 description = "Library with base interfaces for LangGraph checkpoint savers."
 authors = []
 requires-python = ">=3.10"
@@ -59,15 +59,9 @@ lint.select = [
   "UP", # pyupgrade
   "B",  # flake8-bugbear
   "I",  # isort
-  "PLC0415",  # import-outside-top-level
-  "RUF100",  # unused noqa directive
   "UP", # pyupgrade
 ]
 lint.ignore = ["E501", "B008"]
-# PLC0415 (import-outside-top-level) is enforced in tests only. Library code
-# still has deferred imports that have not been reviewed, so it stays exempt
-# for now.
-lint.per-file-ignores = { "langgraph/**" = ["PLC0415"] }
 target-version = "py310"
 
 [tool.ty.rules]

libs/checkpoint/tests/test_conformance_delta.py

@@ -12,14 +12,10 @@ conformance = pytest.importorskip(
 
 @pytest.mark.asyncio
 async def test_delta_channel_conformance():
-    # Imported inside the test: the module-level importorskip above is what
-    # makes these safe, so they cannot move to the top of the file.
-    from langgraph.checkpoint.conformance import validate  # noqa: PLC0415
-    from langgraph.checkpoint.conformance.initializer import (  # noqa: PLC0415
-        checkpointer_test,
-    )
+    from langgraph.checkpoint.conformance import validate
+    from langgraph.checkpoint.conformance.initializer import checkpointer_test
 
-    from langgraph.checkpoint.memory import InMemorySaver  # noqa: PLC0415
+    from langgraph.checkpoint.memory import InMemorySaver
 
     @checkpointer_test(name="InMemorySaver")
     async def mem_saver():

libs/checkpoint/tests/test_encrypted.py

@@ -307,6 +307,8 @@ class TestWithMsgpackAllowlistEncrypted:
             def loads_typed(self, data: tuple[str, bytes]) -> None:
                 return None
 
+        from langgraph.checkpoint.serde.base import CipherProtocol
+
         class DummyCipher(CipherProtocol):
             def encrypt(self, plaintext: bytes) -> tuple[str, bytes]:
                 return "dummy", plaintext

libs/checkpoint/tests/test_jsonplus.py

@@ -1,12 +1,9 @@
 import dataclasses
 import json
 import logging
-import os
 import pathlib
-import pickle
 import re
 import sys
-import tempfile
 import uuid
 from collections import deque
 from datetime import date, datetime, time, timezone
@@ -21,7 +18,7 @@ import ormsgpack
 import pandas as pd
 import pytest
 from langchain_core.documents.base import Document
-from langchain_core.messages import AIMessage, HumanMessage
+from langchain_core.messages import HumanMessage
 from pydantic import BaseModel, SecretStr
 from pydantic.v1 import BaseModel as BaseModelV1
 from pydantic.v1 import SecretStr as SecretStrV1
@@ -344,6 +341,7 @@ def test_lc2_json_safe_type_revives_without_allowlist() -> None:
     constructor dicts. Resuming those threads must reconstruct proper BaseMessage objects
     rather than returning raw dicts that cause MESSAGE_COERCION_FAILURE in add_messages.
     """
+    from langchain_core.messages import AIMessage
 
     serde = JsonPlusSerializer()  # default: _allowed_json_modules=None
 
@@ -412,6 +410,7 @@ def test_lc2_json_method_field_is_ignored() -> None:
     to that method: the result is whatever ``AIMessage(*args, **kwargs)`` would
     produce, which proves the default constructor ran instead of ``parse_raw``.
     """
+    from langchain_core.messages import AIMessage
 
     serde = JsonPlusSerializer()
     load = {
@@ -437,6 +436,7 @@ def test_lc2_json_method_field_is_ignored_for_allowlisted_types() -> None:
     method dispatch as a side effect. Revival is restricted to the default
     constructor regardless of how the class reached the revival path.
     """
+    from langchain_core.messages import AIMessage
 
     serde = JsonPlusSerializer(
         allowed_json_modules=[("langchain_core.messages.ai", "AIMessage")]
@@ -455,6 +455,7 @@ def test_lc2_json_method_field_is_ignored_for_allowlisted_types() -> None:
 
 def test_lc2_json_safe_type_init_still_works() -> None:
     """SAFE-type lc=2 revival without a `method` field still constructs the class."""
+    from langchain_core.messages import AIMessage
 
     serde = JsonPlusSerializer()
     load = {
@@ -478,6 +479,7 @@ def test_lc2_json_legacy_pydantic_method_list_falls_back_to_default() -> None:
     this shape continue to revive correctly as long as the default constructor
     accepts the serialized kwargs.
     """
+    from langchain_core.messages import AIMessage
 
     serde = JsonPlusSerializer()
     load = {
@@ -549,6 +551,9 @@ def test_lc2_json_safe_type_pickle_payload_does_not_execute() -> None:
     With method dispatch removed from `_revive_lc2`, the gadget bytes are never
     passed to `parse_raw` and therefore never reach `pickle.loads`.
     """
+    import os
+    import pickle
+    import tempfile
 
     marker = tempfile.NamedTemporaryFile(
         prefix="lc2_block_proof_", suffix=".out", delete=False

libs/checkpoint/tests/test_memory.py

@@ -1,4 +1,3 @@
-import asyncio
 import logging
 from typing import Any
 
@@ -524,6 +523,7 @@ class TestBaseFallbackGetChannelWrites:
         `threading.local()` guard would let whichever task set it first
         short-circuit the other to `writes=[]`.
         """
+        import asyncio
 
         saver, thread_id, ns = self._build_saver_with_chain()
 
@@ -577,19 +577,9 @@ class TestPreDeltaBlobTerminator:
     """
 
     def _build_mixed_thread(self) -> tuple[InMemorySaver, str, str, str, str]:
-        """Four-checkpoint chain spanning the migration boundary:
-
-        * `cp0` — pre-delta ancestor OLDER than the seed. Its write
-          (`OLDER-WRITE`) is already folded into `cp1`'s stored value, so the
-          walk must terminate at `cp1` and never reach it.
-        * `cp1` — pre-delta, blob `["A"]`. That value is the state ENTERING
-          `cp1`; the write stored under `cp1` (`PRE-DELTA-WRITE`) is what
-          produced `cp2` and is NOT subsumed by the blob.
-        * `cp2` — delta-era, no stored value, write `B`.
-        * `cp3` — target, delta-era, write `PENDING-AT-TARGET`.
-
-        Reconstructing at `cp3` must yield seed `["A"]` plus writes
-        `["PRE-DELTA-WRITE", "B"]`.
+        """Three-checkpoint chain: cp1 (pre-delta, blob=[A]), cp2 (delta,
+        write=B), cp3 (delta, write=C). Reconstructing at cp3 must yield
+        seed=[A] + writes=[B, C].
 
         Returns `(saver, thread_id, ns, channel, cp3_id)`.
         """
@@ -597,21 +587,16 @@ class TestPreDeltaBlobTerminator:
         serde = JsonPlusSerializer()
         thread_id, ns, channel = "t1", "", "messages"
 
-        v0 = "00000000000000000000000000000000.0"
         v1 = "00000000000000000000000000000001.0"
         v2 = "00000000000000000000000000000002.0"
         v3 = "00000000000000000000000000000003.0"
 
-        # Pre-delta: cp0 and cp1 stored real blobs for the channel.
-        saver.blobs[(thread_id, ns, channel, v0)] = serde.dumps_typed([])
+        # Pre-delta: cp1 stored a real blob for the channel.
         saver.blobs[(thread_id, ns, channel, v1)] = serde.dumps_typed(["A"])
         # Delta-era: cp2 and cp3 store "empty"; real writes in checkpoint_writes.
         saver.blobs[(thread_id, ns, channel, v2)] = ("empty", b"")
         saver.blobs[(thread_id, ns, channel, v3)] = ("empty", b"")
 
-        cp0 = empty_checkpoint()
-        cp0["id"] = "cp0"
-        cp0["channel_versions"][channel] = v0
         cp1 = empty_checkpoint()
         cp1["id"] = "cp1"
         cp1["channel_versions"][channel] = v1
@@ -623,24 +608,16 @@ class TestPreDeltaBlobTerminator:
         cp3["channel_versions"][channel] = v3
 
         saver.storage[thread_id][ns] = {
-            "cp0": (serde.dumps_typed(cp0), serde.dumps_typed({}), None),
-            "cp1": (serde.dumps_typed(cp1), serde.dumps_typed({}), "cp0"),
+            "cp1": (serde.dumps_typed(cp1), serde.dumps_typed({}), None),
             "cp2": (serde.dumps_typed(cp2), serde.dumps_typed({}), "cp1"),
             "cp3": (serde.dumps_typed(cp3), serde.dumps_typed({}), "cp2"),
         }
-        # Write under cp0 is older than the seed — cp1's blob already folded
-        # it in, and the terminator must stop before reaching it.
-        saver.writes[(thread_id, ns, "cp0")][("task0", 0)] = (
+        # Write under cp1 would be from the pre-delta era and MUST be ignored
+        # (the blob already captures it). We add one and assert it is not
+        # folded into the reconstructed result.
+        saver.writes[(thread_id, ns, "cp1")][("task0", 0)] = (
             "task0",
             channel,
-            serde.dumps_typed("OLDER-WRITE"),
-            "",
-        )
-        # Write under cp1 postdates cp1's blob (it is what produced cp2, which
-        # stores no value of its own) and MUST be replayed.
-        saver.writes[(thread_id, ns, "cp1")][("task1", 0)] = (
-            "task1",
-            channel,
             serde.dumps_typed("PRE-DELTA-WRITE"),
             "",
         )
@@ -674,19 +651,15 @@ class TestPreDeltaBlobTerminator:
 
         # Seed came from the pre-delta blob at cp1.
         assert result["seed"] == ["A"]
-        # The seed ancestor's own write and the delta-era write from cp2 both
-        # replay through the reducer on top of the seed, oldest first. cp3 is
-        # the target — its own write is pending for the NEXT step and must be
-        # excluded.
+        # Delta-era writes from cp2 replay through the reducer on top of seed.
+        # cp3 is the target — its own write is pending for the NEXT step and
+        # must be excluded.
         values = [v for _, _, v in result["writes"]]
-        assert values == ["PRE-DELTA-WRITE", "B"]
+        assert values == ["B"]
 
-    def test_seed_bounds_walk_without_dropping_its_own_writes(self) -> None:
-        """The seed terminator bounds the walk: writes at ancestors OLDER than
-        the seed are already folded into the seed value and must not be
-        replayed. The seed ancestor's own write is not one of them — it
-        postdates the stored value and produced the next checkpoint.
-        """
+    def test_pre_delta_blob_terminates_walk_before_older_writes(self) -> None:
+        """Writes stored at the pre-delta ancestor itself must not be replayed
+        (the blob subsumes them)."""
         saver, thread_id, ns, channel, target = self._build_mixed_thread()
         config: RunnableConfig = {
             "configurable": {
@@ -701,9 +674,7 @@ class TestPreDeltaBlobTerminator:
         ]
 
         values = [v for _, _, v in result["writes"]]
-        # Older than the seed — subsumed by cp1's blob, so the walk stops first.
-        assert "OLDER-WRITE" not in values
-        # Stored AT the seed ancestor — not subsumed, so it must be replayed.
-        assert "PRE-DELTA-WRITE" in values
+        # The pre-delta write under cp1 must not appear (the blob subsumes it).
+        assert "PRE-DELTA-WRITE" not in values
         # And the pending write at the target is never folded in.
         assert "PENDING-AT-TARGET" not in values

libs/checkpoint/tests/test_store.py

@@ -1,9 +1,7 @@
 import asyncio
 import json
-from collections import UserDict
-from collections.abc import Iterable, Mapping
+from collections.abc import Iterable
 from datetime import datetime
-from types import MappingProxyType
 from typing import Any
 
 import pytest
@@ -139,18 +137,6 @@ def test_get_text_at_path() -> None:
     assert get_text_at_path(nested_data, "nested[{invalid}]") == []
 
 
-@pytest.mark.parametrize(
-    "mapping",
-    [
-        UserDict({"text": "searchable"}),
-        MappingProxyType({"text": "searchable"}),
-    ],
-)
-def test_get_text_at_path_with_non_dict_mapping(mapping: Mapping[str, str]) -> None:
-    assert get_text_at_path(mapping, "$") == ['{"text": "searchable"}']
-    assert get_text_at_path(mapping, "text") == ["searchable"]
-
-
 async def test_async_batch_store(mocker: MockerFixture) -> None:
     abatch = mocker.stub()
 

libs/cli/examples/graphs/storm.py

@@ -236,7 +236,7 @@ def swap_roles(state: InterviewState, name: str):
     converted = []
     for message in state["messages"]:
         if isinstance(message, AIMessage) and message.name != name:
-            message = HumanMessage(**message.model_dump(exclude={"type"}))
+            message = HumanMessage(**message.dict(exclude={"type"}))
         converted.append(message)
     return {"messages": converted}
 

libs/cli/js-examples/package.json

@@ -21,28 +21,25 @@
     "test:all": "yarn test && yarn test:int && yarn lint:langgraph"
   },
   "dependencies": {
-    "@langchain/core": "^1.2.9",
-    "@langchain/langgraph": "^1.4.13"
-  },
-  "resolutions": {
-    "@langchain/langgraph-checkpoint": "1.0.4"
+    "@langchain/core": "^1.1.48",
+    "@langchain/langgraph": "^1.3.3"
   },
   "devDependencies": {
-    "@eslint/eslintrc": "^3.3.6",
+    "@eslint/eslintrc": "^3.3.5",
     "@eslint/js": "^10.0.1",
     "@tsconfig/recommended": "^1.0.13",
     "@types/jest": "^30.0.0",
-    "@typescript-eslint/eslint-plugin": "^8.68.0",
-    "@typescript-eslint/parser": "^8.68.0",
+    "@typescript-eslint/eslint-plugin": "^8.60.1",
+    "@typescript-eslint/parser": "^8.60.1",
     "dotenv": "^17.4.2",
-    "eslint": "^10.9.1",
+    "eslint": "^10.4.1",
     "eslint-config-prettier": "^10.1.8",
     "eslint-plugin-import": "^2.32.0",
     "eslint-plugin-no-instanceof": "^1.0.1",
     "eslint-plugin-prettier": "^5.5.6",
-    "jest": "^30.5.0",
-    "prettier": "^3.9.6",
-    "ts-jest": "^29.4.12",
-    "typescript": "^7.0.2"
+    "jest": "^30.4.2",
+    "prettier": "^3.8.3",
+    "ts-jest": "^29.4.11",
+    "typescript": "^6.0.3"
   }
 }

libs/cli/js-monorepo-example/apps/agent/package.json

@@ -9,10 +9,10 @@
   },
   "dependencies": {
     "@js-monorepo-example/shared": "*",
-    "@langchain/core": "^1.2.9",
-    "@langchain/langgraph": "^1.4.13"
+    "@langchain/core": "^1.1.48",
+    "@langchain/langgraph": "^1.3.3"
   },
   "devDependencies": {
-    "typescript": "^7.0.2"
+    "typescript": "^6.0.3"
   }
 }

libs/cli/js-monorepo-example/libs/shared/package.json

@@ -9,6 +9,6 @@
     "clean": "rm -rf dist"
   },
   "devDependencies": {
-    "typescript": "^7.0.2"
+    "typescript": "^6.0.3"
   }
 }

libs/cli/js-monorepo-example/package.json

@@ -17,18 +17,18 @@
     "lint": "eslint 'apps/**/*.ts' 'libs/**/*.ts'"
   },
   "devDependencies": {
-    "turbo": "^2.10.12",
-    "typescript": "^7.0.2",
+    "turbo": "^2.9.16",
+    "typescript": "^6.0.3",
     "@tsconfig/recommended": "^1.0.13",
-    "@eslint/eslintrc": "^3.3.6",
+    "@eslint/eslintrc": "^3.3.5",
     "@eslint/js": "^10.0.1",
-    "eslint": "^10.9.1",
+    "eslint": "^10.4.1",
     "eslint-config-prettier": "^10.1.8",
     "eslint-plugin-import": "^2.27.5",
     "eslint-plugin-no-instanceof": "^1.0.1",
     "eslint-plugin-prettier": "^5.5.6",
-    "@typescript-eslint/eslint-plugin": "^8.68.0",
-    "@typescript-eslint/parser": "^8.68.0",
-    "prettier": "^3.9.6"
+    "@typescript-eslint/eslint-plugin": "^8.60.1",
+    "@typescript-eslint/parser": "^8.60.1",
+    "prettier": "^3.8.3"
   }
 }

libs/cli/js-monorepo-example/yarn.lock

@@ -28,10 +28,10 @@
     debug "^4.3.1"
     minimatch "^10.2.4"
 
-"@eslint/config-helpers@^0.7.0":
-  version "0.7.0"
-  resolved "https://registry.yarnpkg.com/@eslint/config-helpers/-/config-helpers-0.7.0.tgz#09ee4aa07b73f059ec2d4c74bf4b2ff02b322377"
-  integrity sha512-DObd/KKUsU+FaFv4PLxSRenpXfQWmPXXP3pPZ6/K1PCrMu2vQpMDMuQe/BqYeoLcz8ro0bVDF1RxOJgfVEdhUw==
+"@eslint/config-helpers@^0.6.0":
+  version "0.6.0"
+  resolved "https://registry.yarnpkg.com/@eslint/config-helpers/-/config-helpers-0.6.0.tgz#ef9a36881d39dfd5dbeac22b0da997fabfb08b03"
+  integrity sha512-ii6Bw9jJ2zi2cWA2Z+9/QZ/+3DX6kwaV5Q986D/CdP3Lap3w/pgQZ373FV7byY/i7L4IRH/G43I5dz1ClsCbpA==
   dependencies:
     "@eslint/core" "^1.2.1"
 
@@ -42,10 +42,10 @@
   dependencies:
     "@types/json-schema" "^7.0.15"
 
-"@eslint/eslintrc@^3.3.6":
-  version "3.3.6"
-  resolved "https://registry.yarnpkg.com/@eslint/eslintrc/-/eslintrc-3.3.6.tgz#d22bfd6b3a7d8e1f2c0b2f2e6de111b53ec6e13e"
-  integrity sha512-l2Ul9PrHsPCKcEY/ac7VgFj9D80C7S68sOKc618SyHDPK36s1XcFebXY0iTzUVn4Yq+YbwvSnDmCz9yxjX+QrA==
+"@eslint/eslintrc@^3.3.5":
+  version "3.3.5"
+  resolved "https://registry.yarnpkg.com/@eslint/eslintrc/-/eslintrc-3.3.5.tgz#c131793cfc1a7b96f24a83e0a8bbd4b881558c60"
+  integrity sha512-4IlJx0X0qftVsN5E+/vGujTRIFtwuLbNsVUe7TO6zYPDR1O6nFwvwhIKEKSrl6dZchmYBITazxKoUYOjdtjlRg==
   dependencies:
     ajv "^6.14.0"
     debug "^4.3.2"
@@ -53,7 +53,7 @@
     globals "^14.0.0"
     ignore "^5.2.0"
     import-fresh "^3.2.1"
-    js-yaml "^4.3.0"
+    js-yaml "^4.1.1"
     minimatch "^3.1.5"
     strip-json-comments "^3.1.1"
 
@@ -103,10 +103,10 @@
   resolved "https://registry.yarnpkg.com/@isaacs/cliui/-/cliui-9.0.0.tgz#4d0a3f127058043bf2e7ee169eaf30ed901302f3"
   integrity sha512-AokJm4tuBHillT+FpMtxQ60n8ObyXBatq7jD2/JA9dxbDDokKQm8KMht5ibGzLVU9IJDIKK4TPKgMHEYMn3lMg==
 
-"@langchain/core@^1.2.9":
-  version "1.2.9"
-  resolved "https://registry.yarnpkg.com/@langchain/core/-/core-1.2.9.tgz#4f5fb27ba07c51ce4fb8e1dc32eb36945737afa1"
-  integrity sha512-conzSEj9Zu1AyXJLXsSbgrtxtxinmI1yGqQ5CIJZSoV5rvv+yvQE/vgBnoySpBQ/bl3YPgj2FL/gbDjWykLSfg==
+"@langchain/core@^1.1.48":
+  version "1.1.48"
+  resolved "https://registry.yarnpkg.com/@langchain/core/-/core-1.1.48.tgz#dfe7f6a64b0e3e79e5357ed4b402c021ee315a7f"
+  integrity sha512-fQU6Guyb1pwc2fEplmA8FPbKfOMAofjnyJzExevro0FxEiuGHE18Ov/ZHmT9trWCDTZRI9eW1VIc6aChxV8pAQ==
   dependencies:
     "@cfworker/json-schema" "^4.0.2"
     "@standard-schema/spec" "^1.1.0"
@@ -116,40 +116,39 @@
     p-queue "^6.6.2"
     zod "^3.25.76 || ^4"
 
-"@langchain/langgraph-checkpoint@^1.1.5":
-  version "1.1.5"
-  resolved "https://registry.yarnpkg.com/@langchain/langgraph-checkpoint/-/langgraph-checkpoint-1.1.5.tgz#c793177f9afcce31a1e9922f317f88fec1254282"
-  integrity sha512-BwDwl5VeTOh6CVuiIPgsUgfK51vTJDMSbFcSCUfjJWsl8/DPdK/mbv+ejxJstkSk/BlSPMP4JfXWcN6jD2ea2Q==
-
-"@langchain/langgraph-sdk@~1.10.0":
-  version "1.10.0"
-  resolved "https://registry.yarnpkg.com/@langchain/langgraph-sdk/-/langgraph-sdk-1.10.0.tgz#6ec1364a97caf615983161ae1f00b196897b9cd6"
-  integrity sha512-cPPkh+hMNgeOaGtJRrqs1AjZde45cG2+Ma9Sc10wz2RyvT8SKToCKS+VvkS18SsLajnmq6/FKVmthq6rnUVYOw==
+"@langchain/langgraph-checkpoint@^1.0.4":
+  version "1.0.4"
+  resolved "https://registry.yarnpkg.com/@langchain/langgraph-checkpoint/-/langgraph-checkpoint-1.0.4.tgz#893aa7255b2fe810fdeb50281f6750a3b0a6fef7"
+  integrity sha512-1y5MgZ0gXXrtmoy56e3kaBChI3GwFPIKl27xkrHwN+VE/3iUsyr9gO3Jtp7kdKAe6diZGbcas5bdC/r0yUwTZA==
   dependencies:
-    "@langchain/protocol" "^0.0.19"
+    uuid "^14.0.0"
+
+"@langchain/langgraph-sdk@~1.9.11":
+  version "1.9.11"
+  resolved "https://registry.yarnpkg.com/@langchain/langgraph-sdk/-/langgraph-sdk-1.9.11.tgz#d16f18b2c48e544436489172d86b3c78524eb679"
+  integrity sha512-mhadkZy4LQ97NJwvATiVIkSxVfOnauXNhrVHFgGnzyqr5zzPLS0VIKJW9xKT+pM8yLqW8Qj6+nPPNhwGUaxoRw==
+  dependencies:
+    "@langchain/protocol" "^0.0.16"
     "@types/json-schema" "^7.0.15"
     p-queue "^9.0.1"
     p-retry "^7.1.1"
+    uuid "^14.0.0"
 
-"@langchain/langgraph@^1.4.13":
-  version "1.4.13"
-  resolved "https://registry.yarnpkg.com/@langchain/langgraph/-/langgraph-1.4.13.tgz#168ab4f05c212fd5ab4b2816bcad2e963b345101"
-  integrity sha512-LO1ak6jNQ9jR13tm7Ay4Yh2/otrH7LNVUwWTAI7WJigVdW5Fb6LuYSZUzVn4S7sVSiyVFfnrUcDTd8c7eAzPrQ==
+"@langchain/langgraph@^1.3.3":
+  version "1.3.3"
+  resolved "https://registry.yarnpkg.com/@langchain/langgraph/-/langgraph-1.3.3.tgz#c7bb19029e37971116e07101be3d8fd4b6483d50"
+  integrity sha512-8xbpGUQNBcWua7ivT5vUvDnQ+6Qbt0JO8RisgXZ8guPXNqh8plGVvrODW68S4AlJbOYY2yi0ROKtrL/1yN3MBQ==
   dependencies:
-    "@langchain/langgraph-checkpoint" "^1.1.5"
-    "@langchain/langgraph-sdk" "~1.10.0"
-    "@langchain/protocol" "^0.0.18"
+    "@langchain/langgraph-checkpoint" "^1.0.4"
+    "@langchain/langgraph-sdk" "~1.9.11"
+    "@langchain/protocol" "^0.0.16"
     "@standard-schema/spec" "1.1.0"
+    uuid "^14.0.0"
 
-"@langchain/protocol@^0.0.18":
-  version "0.0.18"
-  resolved "https://registry.yarnpkg.com/@langchain/protocol/-/protocol-0.0.18.tgz#6d96155e7263c958fbce6d4b7241b4725b72fbad"
-  integrity sha512-XW1egQtPfsGI41w2AMZNFZrUIwFSQHTjVMZs0OaTpCAvht/QLoaPN8FQcsysMVypOhupG28J29yOorrc70otBQ==
-
-"@langchain/protocol@^0.0.19":
-  version "0.0.19"
-  resolved "https://registry.yarnpkg.com/@langchain/protocol/-/protocol-0.0.19.tgz#7fe43fed115dc34b3b4c246e8d5283fbcbfab7b0"
-  integrity sha512-9hKcRrH7cBX6gfutdfXPoft1OCchHe4FEpALoDJMl5Qu+n/YG5ynZmyu8+8cxORlPwHBoKTxggvXz+76M1yX1Q==
+"@langchain/protocol@^0.0.16":
+  version "0.0.16"
+  resolved "https://registry.yarnpkg.com/@langchain/protocol/-/protocol-0.0.16.tgz#68b63d58feaf4f0acf77405cb8fb16f9c3f09b60"
+  integrity sha512-ws+J7MaHyhO5dG7f0vdyHQiUn9hoCnki0f3crJPa4MCTGzcRC39jYSCghyrGtBPYQnZbUQiGyRVpW3z3M8IpJg==
 
 "@pkgr/core@^0.3.6":
   version "0.3.6"
@@ -171,35 +170,35 @@
   resolved "https://registry.yarnpkg.com/@tsconfig/recommended/-/recommended-1.0.13.tgz#269fce3ad04ca70b93269ff44cca81b950f542da"
   integrity sha512-sySRuBfMKyKO/j2ZAhR8kSembhjuPEV4Ra3AHtmWLq51+iGaudr45crPSzNC5b7/Ctrh9dfUpBuTlYrH6rM58Q==
 
-"@turbo/darwin-64@2.10.12":
-  version "2.10.12"
-  resolved "https://registry.yarnpkg.com/@turbo/darwin-64/-/darwin-64-2.10.12.tgz#719ac12ae47caf7b4be855d672582cdbfde177ea"
-  integrity sha512-9nKgKoF6ZOUsM+or0OtNf+TTJSfGvDNP7ZFv/ZGWVwOSCkumyctQiTeHwB4UNljHTnC41AqylgbunLDHoccNrA==
+"@turbo/darwin-64@2.9.16":
+  version "2.9.16"
+  resolved "https://registry.yarnpkg.com/@turbo/darwin-64/-/darwin-64-2.9.16.tgz#f4146eab98e020d658a9a5d7feb846acba653546"
+  integrity sha512-jLjApWTSNd7JZ5JaLYfelW1ytnGQOvB7ivl+2RD1xQvJTbi8I9gBjzcga7tDZVPyaxpl10YTfJt3BrYXR18KDw==
 
-"@turbo/darwin-arm64@2.10.12":
-  version "2.10.12"
-  resolved "https://registry.yarnpkg.com/@turbo/darwin-arm64/-/darwin-arm64-2.10.12.tgz#ac2d3dde3a2407f8359ca2e3152690280cff2714"
-  integrity sha512-H4Elb1jqTZVeIC9bbcNwjSzemZ6RegoTOVHeuV5Osirt2Z8UguTyisMEkvZjPVZgMeN9J4ERZBFad40tFnkb7w==
+"@turbo/darwin-arm64@2.9.16":
+  version "2.9.16"
+  resolved "https://registry.yarnpkg.com/@turbo/darwin-arm64/-/darwin-arm64-2.9.16.tgz#1d01ca232fc189045d6a4dba4741f462e0343b8c"
+  integrity sha512-YPgrn+5HIGzrx0O2a631SV4MBQUe4W/DafMFUuBVgaU32PW9/OTT0ehviF0QSxTXuRJlHvW2eUTemddF5/spmw==
 
-"@turbo/linux-64@2.10.12":
-  version "2.10.12"
-  resolved "https://registry.yarnpkg.com/@turbo/linux-64/-/linux-64-2.10.12.tgz#264a0ec88a1f69f93cf57dab20be1b4c50bf226c"
-  integrity sha512-lr7KIotukvjZwEXiFSYAeOH3BWzjFVBbSzTbv0fuGFsNukYyH0+g1hB5ecqnJkgkYU+KHEMG1edOhnjiKON1wQ==
+"@turbo/linux-64@2.9.16":
+  version "2.9.16"
+  resolved "https://registry.yarnpkg.com/@turbo/linux-64/-/linux-64-2.9.16.tgz#8db630e6e5681a2ea48f7df1bca57bbd9bdf3e25"
+  integrity sha512-vAEf1H6l26lTpl9FJ/peQo1NUB8RC0sbEJJz5mPcUhHA2bPDup2x3CZPgo/bH8S4cUcBLm4FN3UHd5iUO2RAew==
 
-"@turbo/linux-arm64@2.10.12":
-  version "2.10.12"
-  resolved "https://registry.yarnpkg.com/@turbo/linux-arm64/-/linux-arm64-2.10.12.tgz#3ee53d1f930d2bb65708e904971be0e765381e37"
-  integrity sha512-f0pZDTtvzB5SuNwuXBaKbZHUCMCukgc8nMlHEuvLmj91Fzec+MEbr3cAvGNor5htEDqZnO6Lxt9N/GPI/77oGA==
+"@turbo/linux-arm64@2.9.16":
+  version "2.9.16"
+  resolved "https://registry.yarnpkg.com/@turbo/linux-arm64/-/linux-arm64-2.9.16.tgz#d1de82fc8075c4774b214dd2f5e8e2570bb03643"
+  integrity sha512-xDBLR2PZg4BrQOchfG6svgpv5FCNJ2TOtT2psLdEJcdKo1BH+pnPs9Xj6pvUjgfkHbuvBOfeE4R6tvxMoQKDHQ==
 
-"@turbo/windows-64@2.10.12":
-  version "2.10.12"
-  resolved "https://registry.yarnpkg.com/@turbo/windows-64/-/windows-64-2.10.12.tgz#ac0a0b7794f9a541e68e930383f48747f7e648ab"
-  integrity sha512-SDOueJRjS/QcykWf2KCRtTLmIl5YMKsLbXkXQGhDwcTXvKXZiS5ih5lBl/gkwZIpYFjqA/rAlfMzlAFcVHNe0g==
+"@turbo/windows-64@2.9.16":
+  version "2.9.16"
+  resolved "https://registry.yarnpkg.com/@turbo/windows-64/-/windows-64-2.9.16.tgz#e369c51edd737978651c2f6b4ce49b582976d66f"
+  integrity sha512-NBAJnaUiGdgkSzQwUIdOvkCkcpTSu58G/sBGa0mvBtzfvFOOgrQwepKOOQ8cp6sWM6OcKDNFj2p1dsZA1OWjPg==
 
-"@turbo/windows-arm64@2.10.12":
-  version "2.10.12"
-  resolved "https://registry.yarnpkg.com/@turbo/windows-arm64/-/windows-arm64-2.10.12.tgz#50eb6c20a20d0aab216d2b6aa13cc3100ea44106"
-  integrity sha512-0i0mVUa4kKk+/B3RwEwPMf9CB+T7ul56hn5FFHNA4VUNTOoLBEd6aNf3FaKfCatDNZ6cicCEf6if9QUTVyzzcA==
+"@turbo/windows-arm64@2.9.16":
+  version "2.9.16"
+  resolved "https://registry.yarnpkg.com/@turbo/windows-arm64/-/windows-arm64-2.9.16.tgz#dbb2b2863e80eb9ca8da8bd8da63e2cc457e470c"
+  integrity sha512-Y7SJppD0Z8wjO3Ec0ZGd9KQ4Yv0BMnA8CIowj5Vp+OEVsosXDG2weK6/t1RRLfJmc2Ozrnd6y4DOgQys+mn3WQ==
 
 "@types/esrecurse@^4.3.1":
   version "4.3.1"
@@ -221,212 +220,102 @@
   resolved "https://registry.yarnpkg.com/@types/json5/-/json5-0.0.29.tgz#ee28707ae94e11d2b827bcbe5270bcea7f3e71ee"
   integrity sha512-dRLjCWHYg4oaA77cxO64oO+7JwCwnIzkZPdrrC71jQmQtlhM556pwKo5bUzqvZndkVbeFLIIi+9TC40JNF5hNQ==
 
-"@typescript-eslint/eslint-plugin@^8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/eslint-plugin/-/eslint-plugin-8.68.0.tgz#a8fbdb1cf49aafaf16071b646daad890151bd149"
-  integrity sha512-WASHDpCm6qO5jj9g1a+8NiW5+GCkAyLReR56/4VruYmNgfUmqpxOfZ2Yfb8xGfJPWv5Qi6LSD8sXdces3vbp/Q==
+"@typescript-eslint/eslint-plugin@^8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/eslint-plugin/-/eslint-plugin-8.60.1.tgz#c1060bb8fa4be80624d3f3dec8dd9caca373af76"
+  integrity sha512-JQ4S5GB0tfjO8BuJ4fcX+HodkzJjYBV+7OJ+wLygaX7OGQ7FudyHL4NSCA6ob+w3Yn+5MkKIozOwQhXeM7opVg==
   dependencies:
     "@eslint-community/regexpp" "^4.12.2"
-    "@typescript-eslint/scope-manager" "8.68.0"
-    "@typescript-eslint/type-utils" "8.68.0"
-    "@typescript-eslint/utils" "8.68.0"
-    "@typescript-eslint/visitor-keys" "8.68.0"
+    "@typescript-eslint/scope-manager" "8.60.1"
+    "@typescript-eslint/type-utils" "8.60.1"
+    "@typescript-eslint/utils" "8.60.1"
+    "@typescript-eslint/visitor-keys" "8.60.1"
     ignore "^7.0.5"
     natural-compare "^1.4.0"
     ts-api-utils "^2.5.0"
 
-"@typescript-eslint/parser@^8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/parser/-/parser-8.68.0.tgz#61de31481354c50457bc9621a7ed746779f09ee7"
-  integrity sha512-fHq2VC1kpyYfvEcbiMjOpySY4WS7voEp89yAThrHRX5sm9j2lzYppCb2umFMEed4fWcyeLjHxrz0mpjNBaBxMQ==
+"@typescript-eslint/parser@^8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/parser/-/parser-8.60.1.tgz#a9d7f30850384d34b41f4687dd8944823c09e289"
+  integrity sha512-A0M6ua6H252bVjPvvtSgl2QA4+ET9S5Mtkb2GDyTxIhH/C4qDItT7RQNO5PhMC6NXGYXOR9dIalcDDgBKT7oFA==
   dependencies:
-    "@typescript-eslint/scope-manager" "8.68.0"
-    "@typescript-eslint/types" "8.68.0"
-    "@typescript-eslint/typescript-estree" "8.68.0"
-    "@typescript-eslint/visitor-keys" "8.68.0"
+    "@typescript-eslint/scope-manager" "8.60.1"
+    "@typescript-eslint/types" "8.60.1"
+    "@typescript-eslint/typescript-estree" "8.60.1"
+    "@typescript-eslint/visitor-keys" "8.60.1"
     debug "^4.4.3"
 
-"@typescript-eslint/project-service@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/project-service/-/project-service-8.68.0.tgz#ea4b2869f59165c420cd7a4bbebc38039794e8cc"
-  integrity sha512-5GQtWZCXFcFYux955pvoS02WLc49pXNlvIxocKjS0clvwo3in1RdlzVKyiqQH9vE5AKWFLTaUgeQkOrTS+0Qxw==
+"@typescript-eslint/project-service@8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/project-service/-/project-service-8.60.1.tgz#eb29712f58d72c222fc727162e92f2ab4670971b"
+  integrity sha512-eXkTH2bxmXlqD1RnOPmLZ9ZM9D3VwSx04JOwBnP9RQ+yUA5a2Mu7SfW8uaV2Aon53NJzZlZYuX7tn91Izf+xaw==
   dependencies:
-    "@typescript-eslint/tsconfig-utils" "^8.68.0"
-    "@typescript-eslint/types" "^8.68.0"
+    "@typescript-eslint/tsconfig-utils" "^8.60.1"
+    "@typescript-eslint/types" "^8.60.1"
     debug "^4.4.3"
 
-"@typescript-eslint/scope-manager@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/scope-manager/-/scope-manager-8.68.0.tgz#e5a13a1159497faeab4e48279bf07576045b1499"
-  integrity sha512-T5eXpcaJNg8bhjHJ8Rjp68Vq/QBteYtTKY8TZqVNPaUbuz0f6jI9t6aDkylwvalpAB9XTTFeFOjrjXAZ3YvmVA==
+"@typescript-eslint/scope-manager@8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/scope-manager/-/scope-manager-8.60.1.tgz#2f875962eaad0a0789cc3c36aea9b4ddeb2dd9c8"
+  integrity sha512-gvI5OQoptnxQnchOirukCuQ55svJSTuD/4k5+pC267xyBtYry748R9/c3tYUzb/iE6RZfllRz2lVulLCHkTm4w==
   dependencies:
-    "@typescript-eslint/types" "8.68.0"
-    "@typescript-eslint/visitor-keys" "8.68.0"
+    "@typescript-eslint/types" "8.60.1"
+    "@typescript-eslint/visitor-keys" "8.60.1"
 
-"@typescript-eslint/tsconfig-utils@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/tsconfig-utils/-/tsconfig-utils-8.68.0.tgz#594d7a3c5952055b3c431fc563ca7fd1defcce18"
-  integrity sha512-F7zrGQfiJHojPwi8vhxZQC1tWtJzvL74cK/nqri2lk8YUXvYaYwl263xOJ69jDWPUk1hmcdoayFwk9lX09npVw==
+"@typescript-eslint/tsconfig-utils@8.60.1", "@typescript-eslint/tsconfig-utils@^8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/tsconfig-utils/-/tsconfig-utils-8.60.1.tgz#bee8b942a13679a878101c9c74577d732062ed93"
+  integrity sha512-nh8w4qAteiKuZu3pSSzG/yGKpw0OlkrKnzFmbVRenKaD4qc+7i1GrmZaLVkr8rk4uipiPGMOW4YsM6WmKZ5CvA==
 
-"@typescript-eslint/tsconfig-utils@^8.68.0":
-  version "8.69.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/tsconfig-utils/-/tsconfig-utils-8.69.0.tgz#d3b0ccc781ab252a90a0b3989b9d1eb85ab59469"
-  integrity sha512-xNqK7YTDZsLniQMV/4rpFR8Z5JlqeRvVjuG1YgF/mdPVH84HSD19L8CczMA0qg2RfwEV231GHH3VnToJDo4MfQ==
-
-"@typescript-eslint/type-utils@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/type-utils/-/type-utils-8.68.0.tgz#8f3e838dbd740909db27053857468cd037b00220"
-  integrity sha512-X77zqoY1EjeWGs/0JNxeaMfp5C5lIz4Tw8y66F1Ne8Faq6g424sBNYM6xBAqElfGZPLpWS+CZAp0DXyKDzWiHg==
+"@typescript-eslint/type-utils@8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/type-utils/-/type-utils-8.60.1.tgz#1ae45f0f2a701354beea4a58c2161e40a5e3c379"
+  integrity sha512-sdwTrpjosW7ANQYJ39ZBF1ZyEMEGVB2UsikrserVM/30a/F1dTLnu9bGxEdosugyu5caigjLrR2qiD11asjI1A==
   dependencies:
-    "@typescript-eslint/types" "8.68.0"
-    "@typescript-eslint/typescript-estree" "8.68.0"
-    "@typescript-eslint/utils" "8.68.0"
+    "@typescript-eslint/types" "8.60.1"
+    "@typescript-eslint/typescript-estree" "8.60.1"
+    "@typescript-eslint/utils" "8.60.1"
     debug "^4.4.3"
     ts-api-utils "^2.5.0"
 
-"@typescript-eslint/types@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/types/-/types-8.68.0.tgz#3f9d4e62fbe5728f09403cdc7b4d58af842ac1af"
-  integrity sha512-9RnpsGJjrAllCMefGVVsImJM24YurhC0Q1h4UbvivtvOqXmR/vEJge2OoE++z9m6hyg8T1Q8t5SNT6tHSbrxcg==
+"@typescript-eslint/types@8.60.1", "@typescript-eslint/types@^8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/types/-/types-8.60.1.tgz#ccdc482ba9e17f9723a10ce240b5e67dad3046c4"
+  integrity sha512-4h0tY8ppCkdCzcrl2YM5M3my0xsE1Tf8om3owEu5oPWmXwkKRmk0j0LGDzYBGUcAlesEbxBhazqu/K4cu3Ug7w==
 
-"@typescript-eslint/types@^8.68.0":
-  version "8.69.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/types/-/types-8.69.0.tgz#5d9ad3f707c2e4f70a2db540031104df3e63bcf5"
-  integrity sha512-K3VrubUPhlo9VDBS6QdI8YB5j7ClpqLRdefcz6PFrhnwicehBweqQ9Evhl4l+FYz0HdDmMqIiSX0aldGRYtDCA==
-
-"@typescript-eslint/typescript-estree@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/typescript-estree/-/typescript-estree-8.68.0.tgz#bf4165029825138ac27231a3ff02923ecd977f38"
-  integrity sha512-OKKsD0tYmoNiU5PW2zehO1yO56jYOm1ShYlxon/Z0SJNidAkdVg86eg9ruRuoXf8xfnuWZGbwDsStkoXbZtIIA==
+"@typescript-eslint/typescript-estree@8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/typescript-estree/-/typescript-estree-8.60.1.tgz#016630b119228bf483ddc652703a6a038f3fdd74"
+  integrity sha512-alpRkfG8hlVE5kdJW2GkfgDgXxold3e8e4l6EnmhRmRLbekgAPCCGDVD++sABy9FcgPFroq+uFcCSM1vR57Cew==
   dependencies:
-    "@typescript-eslint/project-service" "8.68.0"
-    "@typescript-eslint/tsconfig-utils" "8.68.0"
-    "@typescript-eslint/types" "8.68.0"
-    "@typescript-eslint/visitor-keys" "8.68.0"
+    "@typescript-eslint/project-service" "8.60.1"
+    "@typescript-eslint/tsconfig-utils" "8.60.1"
+    "@typescript-eslint/types" "8.60.1"
+    "@typescript-eslint/visitor-keys" "8.60.1"
     debug "^4.4.3"
     minimatch "^10.2.2"
     semver "^7.7.3"
     tinyglobby "^0.2.15"
     ts-api-utils "^2.5.0"
 
-"@typescript-eslint/utils@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/utils/-/utils-8.68.0.tgz#00547f2c8de8aca2a3c21752a9711f73206fd36d"
-  integrity sha512-PB5gJMMOg0Q5P1tsgWtEAqQacJXq0qEqRHDX/YJ4FaTMLfZPpHB3gjl2EJuiZyPABxmj4ZQYiY9m1bdAJ5y7tQ==
+"@typescript-eslint/utils@8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/utils/-/utils-8.60.1.tgz#31cf566095602d9fe8ad91837d2eb520b8de762b"
+  integrity sha512-h2MPBLoNtjc3qZWfY3Tl51yPorQ2McHn8pJfcMNTcIvrrZrr90Ykffit0yjrPFWQcRcUxzH20+6OcVdW4yHtUg==
   dependencies:
     "@eslint-community/eslint-utils" "^4.9.1"
-    "@typescript-eslint/scope-manager" "8.68.0"
-    "@typescript-eslint/types" "8.68.0"
-    "@typescript-eslint/typescript-estree" "8.68.0"
+    "@typescript-eslint/scope-manager" "8.60.1"
+    "@typescript-eslint/types" "8.60.1"
+    "@typescript-eslint/typescript-estree" "8.60.1"
 
-"@typescript-eslint/visitor-keys@8.68.0":
-  version "8.68.0"
-  resolved "https://registry.yarnpkg.com/@typescript-eslint/visitor-keys/-/visitor-keys-8.68.0.tgz#78db3c9bb258a0309d9e2b1b617127c3a8fb1f54"
-  integrity sha512-YR65gGdGvTUAWLldC3xLOvOzamdGzB4A5/N8rehEaHs3Zvoe39BhgY+u0SPch1OvrVTfLcc55wsSgK2NcnTS/A==
+"@typescript-eslint/visitor-keys@8.60.1":
+  version "8.60.1"
+  resolved "https://registry.yarnpkg.com/@typescript-eslint/visitor-keys/-/visitor-keys-8.60.1.tgz#165d1d8901137b944efaf18f00ab5ecb57f06995"
+  integrity sha512-EbGRQg4FhrmwLodl+t3JNAnXHWVr9Vp+Zl1QBZVPY4ByfkzIT8cX3K6QWODHtkIZqqJVEWvhHSx3v5PDHsaQag==
   dependencies:
-    "@typescript-eslint/types" "8.68.0"
+    "@typescript-eslint/types" "8.60.1"
     eslint-visitor-keys "^5.0.0"
 
-"@typescript/typescript-aix-ppc64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-aix-ppc64/-/typescript-aix-ppc64-7.0.2.tgz#cdc7ce81d60f1e09034960ddfb1fb880d7a776b6"
-  integrity sha512-MTKKkWB7p/0E9xi1d1tHtZ5PiLkGEMIq88pK2CubZjOsLtYTLqhgIgi6zepFa+9GHZ6h05NMCkQxGKiPXMxXtQ==
-
-"@typescript/typescript-darwin-arm64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-darwin-arm64/-/typescript-darwin-arm64-7.0.2.tgz#a55fdfcfa58df58d27db2237cde6a5c1e35a7235"
-  integrity sha512-gowzar9MwS/aRWp6f3a4KUqzRjAZjOsmGNCM6LcTgXum+dBfgsBVMN+AgvOCCbguXyick6LJhpBszxMebJ8syA==
-
-"@typescript/typescript-darwin-x64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-darwin-x64/-/typescript-darwin-x64-7.0.2.tgz#38d1c9172800a91d707bec64d2a370a016634db4"
-  integrity sha512-SZ9xZInqApNlNGc9s0W1VSsktYSOe9cFqNOIqmN1Gs8SmkjKZYFt017G4VwPxASInODuAdbTW7sXiFUf893RgA==
-
-"@typescript/typescript-freebsd-arm64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-freebsd-arm64/-/typescript-freebsd-arm64-7.0.2.tgz#f1ff8810030b35d2b5be0db6a2dc650460ea94fa"
-  integrity sha512-W5NH4y/J0plIIS5b2xvTEkU7JFxyqdMAOgf+Ilhl0vHQXKO5dZoxd+C/jEtq56c4F3wk71RB4BMRQ2XdI+bwYQ==
-
-"@typescript/typescript-freebsd-x64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-freebsd-x64/-/typescript-freebsd-x64-7.0.2.tgz#3d86b03f353c5b1ba95162eb6ce35533bfc294bd"
-  integrity sha512-UMGDx5sTpzNw3WiPebH7l90IWfJggEd+egHt/q6p7/Cm3zqoV7VxkGXt+3DxPIw8CcmvAB0j3sVVfbhX+M4Tpw==
-
-"@typescript/typescript-linux-arm64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-arm64/-/typescript-linux-arm64-7.0.2.tgz#d9334d96d6dac6ff85da9c865588948de939e91f"
-  integrity sha512-Qh4eU4/y3yDjnfjjyPYihMj5/ODIlmt+Bzu17OI+fiSRDW57QmU5SiN63exPRNJPKUzcc1INa1NXdrJ+MqHjUQ==
-
-"@typescript/typescript-linux-arm@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-arm/-/typescript-linux-arm-7.0.2.tgz#ad94b41e1aee2a4dcc6a298c7b67c43345fde32e"
-  integrity sha512-gffT3xPz9sR7j/YJExkyPntrI0P2EP9XbOyWzth2/Gs0RstK+90RBcO0ncXoXy/beYll1SXw846Nf2zdnEz0QQ==
-
-"@typescript/typescript-linux-loong64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-loong64/-/typescript-linux-loong64-7.0.2.tgz#2965aee4fc873360139d893daafe6397a29138ad"
-  integrity sha512-uEHck9i8hoAzXPiYRib1O7miOnz23SxIeVl6F4LXox+qov1K35jHcEW6VHKvZI+pyvl7fZEP4MCU5LYvIq1GuQ==
-
-"@typescript/typescript-linux-mips64el@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-mips64el/-/typescript-linux-mips64el-7.0.2.tgz#1a887a311bed3a833f80bfd4a9ed37c271936cf0"
-  integrity sha512-R4KvAMnE43W5Qeqb0Ly56O3mWMWIAgsMyz36DCaycd5nbg/9kzm0liw3JocfRqyJY0KPmzFjbswozXyW0DnIYA==
-
-"@typescript/typescript-linux-ppc64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-ppc64/-/typescript-linux-ppc64-7.0.2.tgz#8b63c9b2f445b393eb4e43ec21da225dade3577d"
-  integrity sha512-DORx5b3sd/4S7eayxm4FQv+A7CrkUIGRaHiwI8oiHTAI1fAPWhF4J0vAlkC8biAlHSVVwxMQ3tjZ2/DVbnQiiA==
-
-"@typescript/typescript-linux-riscv64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-riscv64/-/typescript-linux-riscv64-7.0.2.tgz#b6e8a35c289b3ea97a92a41d461aaeed0d3b36e1"
-  integrity sha512-wf0jqEDOjrPRnKwYRyyJDRo11KMbvMFrU+q4zqKyChODBzvlkbhNQfKvLxQCcwTpdDaXSHZTVuh0JoCrKCUMHQ==
-
-"@typescript/typescript-linux-s390x@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-s390x/-/typescript-linux-s390x-7.0.2.tgz#2ef96693be4861f6d17965427e5b009cbbed1a3e"
-  integrity sha512-IkwJc3L7yhytWd/ewjyxNDfOmswCm9GWMJT/ue/dU4aZNbwZeYAetq42VyLmsmSjvoX7z74X6ZaYCtzAr0EuGw==
-
-"@typescript/typescript-linux-x64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-linux-x64/-/typescript-linux-x64-7.0.2.tgz#73269cb0baba50aea0ca060445a6b88e583f1ce2"
-  integrity sha512-EYdf2cNg7rgCWJnxCdJ+F3V39O8ihb37eHAu1LK8oAFizgTQbPOK7zHHXbPt8rX24COqODXeI3sIf0fCXG7H/A==
-
-"@typescript/typescript-netbsd-arm64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-netbsd-arm64/-/typescript-netbsd-arm64-7.0.2.tgz#3a3649f97fafa210b4e6e3798c15e06605c8a901"
-  integrity sha512-+polYF4MF04aPpO5FTkHran9yUQDSXqy5GiSDKpsll5jy3l3+g9QLhpf39T+ePtefhXLOGrLl0QIjkQP6VnelA==
-
-"@typescript/typescript-netbsd-x64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-netbsd-x64/-/typescript-netbsd-x64-7.0.2.tgz#47ec59491a40c470d2807dc4d2b825528fd979ab"
-  integrity sha512-8YIT0EHM/3dq10ZOVF/A7pc/YSMtbcecct4rWtexrnSCHOPcpC2KTLXfTCR6vDpnSiY12heNb1GiN/wu+T/FyA==
-
-"@typescript/typescript-openbsd-arm64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-openbsd-arm64/-/typescript-openbsd-arm64-7.0.2.tgz#796be8da0bd989d8a3fb96f2801e38a8365b4baf"
-  integrity sha512-APT8+ClYnuYm1u9+kgGXoMj2VzWzcymwh2gNSQVySHfkRDGOTVkoWLjCmOQSaO+PoqQ57B0flRp9SA+7GnnkzQ==
-
-"@typescript/typescript-openbsd-x64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-openbsd-x64/-/typescript-openbsd-x64-7.0.2.tgz#d37fe2a729eb942c076c454ee7f1815faf7d560f"
-  integrity sha512-yX7s+Q0Dln0Dt9tEzZsAjXXR/+ytBM7AlglaqyeMPxQszJ1JhlJdZ6jLA+IzldHtflX81em7lDao1xXu+aRRkg==
-
-"@typescript/typescript-sunos-x64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-sunos-x64/-/typescript-sunos-x64-7.0.2.tgz#aba8d3464c3565a7044789baba96916bd4ab2c88"
-  integrity sha512-dLJDGaLZ1D4HPQn62u1n8mBDkJREwMsAkCdkwd4Ieqw+x3TUyTsqY0YiBCtE6H6OzzgGk3iuZ3vFWRS+E8/d1g==
-
-"@typescript/typescript-win32-arm64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-win32-arm64/-/typescript-win32-arm64-7.0.2.tgz#b9de50a17196383f62620b5f9d0a2f34ad3b60d7"
-  integrity sha512-Gyl1Vy6OsWesLzmq+EP0Fb7b4Nid5232AvcA2SFcdYreldpNtYFFofPjnt62y9hQy7VTaZp65ICJjuAQRaVcIQ==
-
-"@typescript/typescript-win32-x64@7.0.2":
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/@typescript/typescript-win32-x64/-/typescript-win32-x64-7.0.2.tgz#cf3b7b0d6ce5635daca4c8e01c189cdcde47ec3c"
-  integrity sha512-0BQ3HkAHHlKLSp1qRvf3SUhGpGsDuhB/jgFw75guyqbxJqEaS0Cw/VFO8i2nHglJUzQCRtMMR/IBAKE3ETMC4g==
-
 acorn-jsx@^5.3.2:
   version "5.3.2"
   resolved "https://registry.yarnpkg.com/acorn-jsx/-/acorn-jsx-5.3.2.tgz#7ed5bb55908b3b2f1bc55c6af1653bada7f07937"
@@ -562,10 +451,10 @@ brace-expansion@^1.1.7:
     balanced-match "^1.0.0"
     concat-map "0.0.1"
 
-brace-expansion@^5.0.8:
-  version "5.0.9"
-  resolved "https://registry.yarnpkg.com/brace-expansion/-/brace-expansion-5.0.9.tgz#7c72438809b5fa5babf54199a1f1c281a6984fcf"
-  integrity sha512-ScQ4IuvIEF1TMlP7Zt+vjJ//9zlPb2SDcxWxM3bk8s6t6GGdJ7KO1dCcTidOPJKePW30LE/2cT7wCyPho9/Wxg==
+brace-expansion@^5.0.2:
+  version "5.0.2"
+  resolved "https://registry.yarnpkg.com/brace-expansion/-/brace-expansion-5.0.2.tgz#b6c16d0791087af6c2bc463f52a8142046c06b6f"
+  integrity sha512-Pdk8c9poy+YhOgVWw1JNN22/HcivgKWwpxKq04M/jTmHyCZn12WPJebZxdjSa5TmBqISrUSgNYU3eRORljfCCw==
   dependencies:
     balanced-match "^4.0.2"
 
@@ -886,15 +775,15 @@ eslint-visitor-keys@^5.0.0, eslint-visitor-keys@^5.0.1:
   resolved "https://registry.yarnpkg.com/eslint-visitor-keys/-/eslint-visitor-keys-5.0.1.tgz#9e3c9489697824d2d4ce3a8ad12628f91e9f59be"
   integrity sha512-tD40eHxA35h0PEIZNeIjkHoDR4YjjJp34biM0mDvplBe//mB+IHCqHDGV7pxF+7MklTvighcCPPZC7ynWyjdTA==
 
-eslint@^10.9.1:
-  version "10.9.1"
-  resolved "https://registry.yarnpkg.com/eslint/-/eslint-10.9.1.tgz#409da5c41a5536d5a849f8555a18ca7ef1eb963b"
-  integrity sha512-9VaAkDURekixUQJy0oJYl2DcN6oKMfxay7XzaGYAWQwsb6qfKf+x76R2k1L8kb1boc+FyCAaTA9GmiKaaiaF+A==
+eslint@^10.4.1:
+  version "10.4.1"
+  resolved "https://registry.yarnpkg.com/eslint/-/eslint-10.4.1.tgz#f6640b176e0912246d9ddbf8fcfa5e8b7f02445a"
+  integrity sha512-AyIKhnOBuOAdueD7RB3xB+YeAWScb9jHsJBgH2Hcde8InP5JYhqrRR6iTMHyTEwgENK54Cp44e4v8BwNhsuHuw==
   dependencies:
     "@eslint-community/eslint-utils" "^4.8.0"
     "@eslint-community/regexpp" "^4.12.2"
     "@eslint/config-array" "^0.23.5"
-    "@eslint/config-helpers" "^0.7.0"
+    "@eslint/config-helpers" "^0.6.0"
     "@eslint/core" "^1.2.1"
     "@eslint/plugin-kit" "^0.7.2"
     "@humanfs/node" "^0.16.6"
@@ -918,7 +807,7 @@ eslint@^10.9.1:
     imurmurhash "^0.1.4"
     is-glob "^4.0.0"
     json-stable-stringify-without-jsonify "^1.0.1"
-    minimatch "^10.2.5"
+    minimatch "^10.2.4"
     natural-compare "^1.4.0"
     optionator "^0.9.3"
 
@@ -1390,10 +1279,10 @@ js-tiktoken@^1.0.12:
   dependencies:
     base64-js "^1.5.1"
 
-js-yaml@^4.3.0:
-  version "4.3.1"
-  resolved "https://registry.yarnpkg.com/js-yaml/-/js-yaml-4.3.1.tgz#01216c001d67f48e2cd560d708c7af21090a3848"
-  integrity sha512-CY6crGq313MX8GkwvB7tzgp99vjQxY1++5y10/BKN/GUfHqWaOGQMNZkBvqSzsZKWk/ijwHlWzzkLulsGHhjWQ==
+js-yaml@^4.1.1:
+  version "4.2.0"
+  resolved "https://registry.yarnpkg.com/js-yaml/-/js-yaml-4.2.0.tgz#2bd9e85682dd91bd469afb809d816043b3d49524"
+  integrity sha512-ePWsvanv0DWuDRsW8dnt+R4jQ31SCRCQ7hhNcPXZPsoBZiemuZNYGf7adZdqX2D86j6rvKp3RpCxVTSb8WQlOw==
   dependencies:
     argparse "^2.0.1"
 
@@ -1453,12 +1342,12 @@ math-intrinsics@^1.1.0:
   resolved "https://registry.yarnpkg.com/math-intrinsics/-/math-intrinsics-1.1.0.tgz#a0dd74be81e2aa5c2f27e65ce283605ee4e2b7f9"
   integrity sha512-/IXtbwEk5HTPyEwyKX6hGkYXxM9nbj64B+ilVJnC/R6B0pH5G4V3b0pVbL7DBj4tkhBAppbQUlf6F6Xl9LHu1g==
 
-minimatch@^10.2.2, minimatch@^10.2.4, minimatch@^10.2.5:
-  version "10.2.6"
-  resolved "https://registry.yarnpkg.com/minimatch/-/minimatch-10.2.6.tgz#fd956bbe0b77241e9f15ac5dccb1c638060968ef"
-  integrity sha512-vpLQEs+VLCr1nU0BXS07maYoFwlDAH0gngQuuttxIwutDFEMHq2blX+8vpgxDdK3J1PwjCJiep77OitTZ4Ll1A==
+minimatch@^10.2.2, minimatch@^10.2.4:
+  version "10.2.4"
+  resolved "https://registry.yarnpkg.com/minimatch/-/minimatch-10.2.4.tgz#465b3accbd0218b8281f5301e27cedc697f96fde"
+  integrity sha512-oRjTw/97aTBN0RHbYCdtF1MQfvusSIBQM0IZEgzl6426+8jSC0nF1a/GmnVLpfB9yyr6g6FTqWqiZVbxrtaCIg==
   dependencies:
-    brace-expansion "^5.0.8"
+    brace-expansion "^5.0.2"
 
 minimatch@^3.1.2, minimatch@^3.1.5:
   version "3.1.5"
@@ -1657,10 +1546,10 @@ prettier-linter-helpers@^1.0.1:
   dependencies:
     fast-diff "^1.1.2"
 
-prettier@^3.9.6:
-  version "3.9.6"
-  resolved "https://registry.yarnpkg.com/prettier/-/prettier-3.9.6.tgz#b3ea5146515d40fc53f18aa63f74dfab1e10dbf6"
-  integrity sha512-OpN0zzVdiaiAhxpuuj5efpIS4sY9j7bY6uR5mnj5yPzGkdkjNKSJeUThPb60Jw29QuAZgA4o+/iB49kFiaBX6g==
+prettier@^3.8.3:
+  version "3.8.3"
+  resolved "https://registry.yarnpkg.com/prettier/-/prettier-3.8.3.tgz#560f2de55bf01b4c0503bc629d5df99b9a1d09b0"
+  integrity sha512-7igPTM53cGHMW8xWuVTydi2KO233VFiTNyF5hLJqpilHfmn8C8gPf+PS7dUT64YcXFbiMGZxS9pCSxL/Dxm/Jw==
 
 punycode@^2.1.0:
   version "2.3.1"
@@ -1913,17 +1802,17 @@ tsconfig-paths@^3.15.0:
     minimist "^1.2.6"
     strip-bom "^3.0.0"
 
-turbo@^2.10.12:
-  version "2.10.12"
-  resolved "https://registry.yarnpkg.com/turbo/-/turbo-2.10.12.tgz#22f552bd88182d58365960a02e5f45e628fb965b"
-  integrity sha512-AswgMPnpOoaVZHrrSBejETzEbuIA69OVGwfkHwfrY0A23VjWXBANzgq9+OymWOHAIArB7D1+1z498WY8fGg1Jw==
+turbo@^2.9.16:
+  version "2.9.16"
+  resolved "https://registry.yarnpkg.com/turbo/-/turbo-2.9.16.tgz#ed72ff679c2c54bde0e3a2e40107416181e203a4"
+  integrity sha512-NqgRQy6j6dPYcdSdv0q1g9QsZg7SWg87RERM8otw/1AtKU2yTFVClOM7cbwKzOonZr/Ek1blTBucw64L9H0Bwg==
   optionalDependencies:
-    "@turbo/darwin-64" "2.10.12"
-    "@turbo/darwin-arm64" "2.10.12"
-    "@turbo/linux-64" "2.10.12"
-    "@turbo/linux-arm64" "2.10.12"
-    "@turbo/windows-64" "2.10.12"
-    "@turbo/windows-arm64" "2.10.12"
+    "@turbo/darwin-64" "2.9.16"
+    "@turbo/darwin-arm64" "2.9.16"
+    "@turbo/linux-64" "2.9.16"
+    "@turbo/linux-arm64" "2.9.16"
+    "@turbo/windows-64" "2.9.16"
+    "@turbo/windows-arm64" "2.9.16"
 
 type-check@^0.4.0, type-check@~0.4.0:
   version "0.4.0"
@@ -1977,31 +1866,10 @@ typed-array-length@^1.0.7:
     possible-typed-array-names "^1.0.0"
     reflect.getprototypeof "^1.0.6"
 
-typescript@^7.0.2:
-  version "7.0.2"
-  resolved "https://registry.yarnpkg.com/typescript/-/typescript-7.0.2.tgz#9ec773d7954a8c182c17cc5bbd575aa28bc51582"
-  integrity sha512-8FYau96o3NKOhbjKi/qNvG/W5jhzxkbdm5sj9AbZ/5T5sWqn3hJgLfGx27sRKZWTvyzCP8dLRBTf5tBTSRVUNA==
-  optionalDependencies:
-    "@typescript/typescript-aix-ppc64" "7.0.2"
-    "@typescript/typescript-darwin-arm64" "7.0.2"
-    "@typescript/typescript-darwin-x64" "7.0.2"
-    "@typescript/typescript-freebsd-arm64" "7.0.2"
-    "@typescript/typescript-freebsd-x64" "7.0.2"
-    "@typescript/typescript-linux-arm" "7.0.2"
-    "@typescript/typescript-linux-arm64" "7.0.2"
-    "@typescript/typescript-linux-loong64" "7.0.2"
-    "@typescript/typescript-linux-mips64el" "7.0.2"
-    "@typescript/typescript-linux-ppc64" "7.0.2"
-    "@typescript/typescript-linux-riscv64" "7.0.2"
-    "@typescript/typescript-linux-s390x" "7.0.2"
-    "@typescript/typescript-linux-x64" "7.0.2"
-    "@typescript/typescript-netbsd-arm64" "7.0.2"
-    "@typescript/typescript-netbsd-x64" "7.0.2"
-    "@typescript/typescript-openbsd-arm64" "7.0.2"
-    "@typescript/typescript-openbsd-x64" "7.0.2"
-    "@typescript/typescript-sunos-x64" "7.0.2"
-    "@typescript/typescript-win32-arm64" "7.0.2"
-    "@typescript/typescript-win32-x64" "7.0.2"
+typescript@^6.0.3:
+  version "6.0.3"
+  resolved "https://registry.yarnpkg.com/typescript/-/typescript-6.0.3.tgz#90251dc007916e972786cb94d74d15b185577d21"
+  integrity sha512-y2TvuxSZPDyQakkFRPZHKFm+KKVqIisdg9/CZwm9ftvKXLP8NRWj38/ODjNbr43SsoXqNuAisEf1GdCxqWcdBw==
 
 unbox-primitive@^1.1.0:
   version "1.1.0"
@@ -2020,6 +1888,11 @@ uri-js@^4.2.2:
   dependencies:
     punycode "^2.1.0"
 
+uuid@^14.0.0:
+  version "14.0.0"
+  resolved "https://registry.yarnpkg.com/uuid/-/uuid-14.0.0.tgz#0af883220163d264ffe0c084f6b8a89b9666966d"
+  integrity sha512-Qo+uWgilfSmAhXCMav1uYFynlQO7fMFiMVZsQqZRMIXp0O7rR7qjkj+cPvBHLgBqi960QCoo/PH2/6ZtVqKvrg==
+
 which-boxed-primitive@^1.1.0, which-boxed-primitive@^1.1.1:
   version "1.1.1"
   resolved "https://registry.yarnpkg.com/which-boxed-primitive/-/which-boxed-primitive-1.1.1.tgz#d76ec27df7fa165f18d5808374a5fe23c29b176e"

libs/cli/langgraph_cli/__init__.py

@@ -1 +1 @@
-__version__ = "0.4.31"
+__version__ = "0.4.30"

libs/cli/langgraph_cli/deploy.py

@@ -366,42 +366,6 @@ def normalize_image_tag(value: str) -> str:
     return value
 
 
-def _validate_prebuilt_image(runner, image: str, *, verbose: bool) -> None:
-    """Ensure a prebuilt image exists locally for linux/amd64."""
-    try:
-        stdout, _ = runner.run(
-            subp_exec(
-                "docker",
-                "image",
-                "inspect",
-                "--format",
-                "{{.Os}}/{{.Architecture}}",
-                image,
-                verbose=verbose,
-                collect=True,
-            )
-        )
-    except FileNotFoundError:
-        raise click.ClickException(
-            "Docker is required but not installed.\n"
-            "Install Docker Desktop: https://docs.docker.com/get-docker/"
-        ) from None
-    except click.exceptions.Exit:
-        raise click.ClickException(
-            f"Docker image '{image}' was not found locally. Build or pull the image "
-            "before deploying with --image."
-        ) from None
-
-    image_platform = (stdout or "").strip()
-    if image_platform != "linux/amd64":
-        detected = image_platform or "unknown"
-        raise click.ClickException(
-            f"Docker image '{image}' targets {detected}, but LangSmith Deployment "
-            "requires linux/amd64. Rebuild or pull the image for linux/amd64 before "
-            "deploying with --image."
-        )
-
-
 def _extract_deployment_url(deployment: dict[str, object]) -> str:
     source_config = deployment.get("source_config")
     if isinstance(source_config, dict):
@@ -561,18 +525,12 @@ def _secrets_from_env(
 
 def _resolve_build_mode(
     remote_build_flag: bool | None,
-    *,
-    force_local: bool = False,
 ) -> tuple[bool, str | None]:
     """Determine whether to use a remote build.
 
     Returns (use_remote_build, local_build_error).  Raises UsageError when
-    --no-remote is set but the machine cannot build locally. When
-    `force_local` is set, the function short-circuits and always selects a
-    local build.
+    --no-remote is set but the machine cannot build locally.
     """
-    if force_local:
-        return False, None
     local_build_supported, local_build_error = can_build_locally()
 
     if remote_build_flag is True:
@@ -939,7 +897,6 @@ def _run_local_build(
     api_version: str | None,
     base_image: str | None,
     image_name: str | None,
-    prebuilt_image: str | None,
     name: str | None,
     tag: str,
     install_command: str | None,
@@ -953,57 +910,51 @@ def _run_local_build(
     # (e.g. Apple Silicon). On amd64 hosts, plain docker build is sufficient.
     needs_buildx = platform.machine() != "x86_64"
     local_tag = f"langgraph-deploy-tmp:{int(time.time())}"
-    image_to_push = prebuilt_image or local_tag
 
     with Runner() as runner:
-        if prebuilt_image:
-            _log_deploy_step(step, f"Validating image {prebuilt_image}")
-            _validate_prebuilt_image(runner, prebuilt_image, verbose=verbose)
-            click.secho("   Image is available for linux/amd64", fg="green")
+        # -- Step: Build image --
+        _log_deploy_step(step, "Building image")
+        if needs_buildx:
+            build_flags: list[str] = [
+                "--platform",
+                "linux/amd64",
+                "--load",
+            ]
+            if not verbose:
+                build_flags.append("--progress=quiet")
+            with Progress(message="Building...", elapsed=not verbose):
+                build_docker_image(
+                    runner,
+                    lambda _msg: None,
+                    config,
+                    config_json,
+                    base_image,
+                    api_version,
+                    pull,
+                    local_tag,
+                    docker_build_args,
+                    install_command,
+                    build_command,
+                    docker_command=("docker", "buildx", "build"),
+                    extra_flags=build_flags,
+                    verbose=verbose,
+                )
         else:
-            # -- Step: Build image --
-            _log_deploy_step(step, "Building image")
-            if needs_buildx:
-                build_flags: list[str] = [
-                    "--platform",
-                    "linux/amd64",
-                    "--load",
-                ]
-                if not verbose:
-                    build_flags.append("--progress=quiet")
-                with Progress(message="Building...", elapsed=not verbose):
-                    build_docker_image(
-                        runner,
-                        lambda _msg: None,
-                        config,
-                        config_json,
-                        base_image,
-                        api_version,
-                        pull,
-                        local_tag,
-                        docker_build_args,
-                        install_command,
-                        build_command,
-                        docker_command=("docker", "buildx", "build"),
-                        extra_flags=build_flags,
-                        verbose=verbose,
-                    )
-            else:
-                with Progress(message="Building...", elapsed=not verbose):
-                    build_docker_image(
-                        runner,
-                        lambda _msg: None,
-                        config,
-                        config_json,
-                        base_image,
-                        api_version,
-                        pull,
-                        local_tag,
-                        docker_build_args,
-                        install_command,
-                        build_command,
-                        verbose=verbose,
-                    )
+            with Progress(message="Building...", elapsed=not verbose):
+                build_docker_image(
+                    runner,
+                    lambda _msg: None,
+                    config,
+                    config_json,
+                    base_image,
+                    api_version,
+                    pull,
+                    local_tag,
+                    docker_build_args,
+                    install_command,
+                    build_command,
+                    verbose=verbose,
+                )
         step += 1
 
         # -- Step: Get push token and authenticate --
@@ -1072,7 +1023,7 @@ def _run_local_build(
                 subp_exec(
                     "docker",
                     "tag",
-                    image_to_push,
+                    local_tag,
                     remote_image,
                     verbose=verbose,
                 )
@@ -1472,13 +1423,6 @@ def _deploy_base_options(
                 show_default=True,
                 help="Tag to use for the pushed deployment image.",
             ),
-            click.option(
-                "--image",
-                help=(
-                    "Use an existing local image reference (e.g. repo:tag) and "
-                    "skip building. The image must target linux/amd64."
-                ),
-            ),
             click.option(
                 "--config",
                 "-c",
@@ -1579,7 +1523,6 @@ def _deploy_cmd(
     deployment_type: str,
     name: str | None,
     image_name: str | None,
-    image: str | None,
     tag: str,
     base_image: str | None,
     install_command: str | None,
@@ -1626,12 +1569,7 @@ def _deploy_cmd(
 
     secrets = _secrets_from_env(_env_without_deployment_name(env_vars))
 
-    if image and remote_build_flag is True:
-        raise click.UsageError("--image cannot be combined with --remote builds.")
-
-    use_remote_build, local_build_error = _resolve_build_mode(
-        remote_build_flag, force_local=image is not None
-    )
+    use_remote_build, local_build_error = _resolve_build_mode(remote_build_flag)
     if use_remote_build and remote_build_flag is None and local_build_error:
         em.note(f"{local_build_error}\nUsing remote build instead.")
         if not json_output:
@@ -1701,7 +1639,6 @@ def _deploy_cmd(
             api_version=api_version,
             base_image=base_image,
             image_name=image_name,
-            prebuilt_image=image,
             name=name,
             tag=tag,
             install_command=install_command,
@@ -1786,12 +1723,8 @@ def deploy_list(api_key: str | None, host_url: str | None, name_contains: str) -
         client,
         lambda c: c.list_deployments(name_contains=name_contains),
     )
-    resources = response.get("resources") if isinstance(response, dict) else None
-    deployments = (
-        [item for item in resources if isinstance(item, dict)]
-        if isinstance(resources, list)
-        else []
-    )
+    resources = response.get("resources", []) if isinstance(response, dict) else []
+    deployments = [item for item in resources if isinstance(item, dict)]
     if not deployments:
         click.echo("No deployments found.")
         return
@@ -1835,12 +1768,8 @@ def deploy_revisions_list(
         client,
         lambda c: c.list_revisions(deployment_id, limit=limit),
     )
-    resources = response.get("resources") if isinstance(response, dict) else None
-    revisions = (
-        [item for item in resources if isinstance(item, dict)]
-        if isinstance(resources, list)
-        else []
-    )
+    resources = response.get("resources", []) if isinstance(response, dict) else []
+    revisions = [item for item in resources if isinstance(item, dict)]
     if not revisions:
         click.echo(f"No revisions found for deployment {deployment_id}.")
         return

libs/cli/langgraph_cli/uv_lock.py

@@ -970,22 +970,6 @@ def python_config_to_docker_uv_lock(
             f"{uv_export_project_dir}/uv.lock",
         )
     )
-    for package_root in sorted(
-        plan.all_workspace_roots,
-        key=lambda root: root.as_posix(),
-    ):
-        if package_root == plan.project_root:
-            continue
-        package_relative_path = pathlib.PurePosixPath(
-            package_root.relative_to(plan.project_root).as_posix()
-        )
-        package_pyproject_path = package_relative_path / "pyproject.toml"
-        docker_plan.add_raw(
-            copy_from_project_root(
-                package_pyproject_path,
-                f"{uv_export_project_dir}/{package_pyproject_path.as_posix()}",
-            )
-        )
     docker_plan.add_instruction("WORKDIR", uv_export_project_dir)
     docker_plan.add_instruction(
         "RUN",

libs/cli/pyproject.toml

@@ -23,7 +23,7 @@ dependencies = [
 path = "langgraph_cli/__init__.py"
 [project.optional-dependencies]
 inmem = [
-    "langgraph-api>=0.5.35,<1.0.0 ; python_version >= '3.11'",
+    "langgraph-api>=0.5.35,<0.12.0 ; python_version >= '3.11'",
     "langgraph-runtime-inmem>=0.7 ; python_version >= '3.11'",
 ]
 
@@ -72,15 +72,9 @@ lint.select = [
   "UP", # pyupgrade
   "B",  # flake8-bugbear
   "I",  # isort
-  "PLC0415",  # import-outside-top-level
-  "RUF100",  # unused noqa directive
   "UP", # pyupgrade
 ]
 lint.ignore = ["E501", "B008"]
-# PLC0415 (import-outside-top-level) is enforced in tests only. Library code
-# still has deferred imports that have not been reviewed, so it stays exempt
-# for now.
-lint.per-file-ignores = { "langgraph_cli/**" = ["PLC0415"], "generate_schema.py" = ["PLC0415"] }
 target-version = "py310"
 
 [tool.ty.rules]

libs/cli/tests/unit_tests/test_archive.py

@@ -11,7 +11,6 @@ from langgraph_cli.archive import (
     _tar_filter,
     create_archive,
 )
-from langgraph_cli.config import LocalDeps
 
 # ---------------------------------------------------------------------------
 # _tar_filter
@@ -199,6 +198,7 @@ class TestCreateArchive:
 
     @patch("langgraph_cli.archive._assemble_local_deps")
     def test_yields_archive_with_config(self, mock_deps, tmp_path):
+        from langgraph_cli.config import LocalDeps
 
         config_file = self._make_project(tmp_path)
         mock_deps.return_value = LocalDeps(
@@ -218,6 +218,7 @@ class TestCreateArchive:
 
     @patch("langgraph_cli.archive._assemble_local_deps")
     def test_excludes_pycache(self, mock_deps, tmp_path):
+        from langgraph_cli.config import LocalDeps
 
         config_file = self._make_project(tmp_path)
         mock_deps.return_value = LocalDeps(
@@ -231,6 +232,7 @@ class TestCreateArchive:
 
     @patch("langgraph_cli.archive._assemble_local_deps")
     def test_cleans_up_tmp_dir_on_normal_exit(self, mock_deps, tmp_path):
+        from langgraph_cli.config import LocalDeps
 
         config_file = self._make_project(tmp_path)
         mock_deps.return_value = LocalDeps(
@@ -245,6 +247,7 @@ class TestCreateArchive:
 
     @patch("langgraph_cli.archive._assemble_local_deps")
     def test_cleans_up_tmp_dir_on_exception(self, mock_deps, tmp_path):
+        from langgraph_cli.config import LocalDeps
 
         config_file = self._make_project(tmp_path)
         mock_deps.return_value = LocalDeps(
@@ -261,6 +264,7 @@ class TestCreateArchive:
     @patch("langgraph_cli.archive._assemble_local_deps")
     @patch("langgraph_cli.archive._MAX_SIZE", 10)
     def test_raises_on_oversized_archive(self, mock_deps, tmp_path):
+        from langgraph_cli.config import LocalDeps
 
         config_file = self._make_project(tmp_path)
         mock_deps.return_value = LocalDeps(
@@ -274,6 +278,7 @@ class TestCreateArchive:
     @patch("langgraph_cli.archive._assemble_local_deps")
     def test_handles_extra_contexts(self, mock_deps, tmp_path):
         """Monorepo case: project + sibling dependency directory."""
+        from langgraph_cli.config import LocalDeps
 
         project = tmp_path / "myproject"
         project.mkdir()

libs/cli/tests/unit_tests/test_config.py

@@ -1403,19 +1403,6 @@ def test_config_to_docker_uv_lock():
             "COPY --from=uv-workspace-root uv.lock /tmp/uv_export/project/uv.lock"
             in docker
         )
-        workspace_pyprojects = [
-            "apps/agent/pyproject.toml",
-            "libs/extra/pyproject.toml",
-            "libs/shared/pyproject.toml",
-        ]
-        export_instruction = "RUN uv export --package agent"
-        for pyproject_path in workspace_pyprojects:
-            copy_instruction = (
-                "COPY --from=uv-workspace-root "
-                f"{pyproject_path} /tmp/uv_export/project/{pyproject_path}"
-            )
-            assert copy_instruction in docker
-            assert docker.index(copy_instruction) < docker.index(export_instruction)
         assert additional_contexts == {"uv-workspace-root": str(project_root.resolve())}
 
         assert (

libs/cli/tests/unit_tests/test_deploy_helpers.py

@@ -1,4 +1,3 @@
-import asyncio
 import base64
 import io
 import json
@@ -7,11 +6,9 @@ import sys
 from unittest.mock import MagicMock
 
 import click
-import click.exceptions
 import httpx
 import pytest
 
-import langgraph_cli.deploy as deploy_mod
 from langgraph_cli.deploy import (
     _call_host_backend_with_optional_tenant,
     _create_host_backend_client,
@@ -22,7 +19,6 @@ from langgraph_cli.deploy import (
     _resolve_env_path,
     _resolve_pushed_image_digest,
     _smith_dashboard_base_url,
-    _validate_prebuilt_image,
     normalize_image_tag,
     normalize_name,
 )
@@ -99,65 +95,6 @@ class TestNormalizeImageTag:
             normalize_image_tag("has space")
 
 
-class _FakeRunner:
-    def run(self, coro):
-        return asyncio.run(coro)
-
-
-class TestValidatePrebuiltImage:
-    def test_accepts_linux_amd64(self, monkeypatch):
-        calls = []
-
-        async def fake_subp_exec(*args, **kwargs):
-            calls.append((args, kwargs))
-            return "linux/amd64\n", None
-
-        monkeypatch.setattr(deploy_mod, "subp_exec", fake_subp_exec)
-
-        _validate_prebuilt_image(_FakeRunner(), "repo/app:tag", verbose=False)
-
-        assert calls == [
-            (
-                (
-                    "docker",
-                    "image",
-                    "inspect",
-                    "--format",
-                    "{{.Os}}/{{.Architecture}}",
-                    "repo/app:tag",
-                ),
-                {"verbose": False, "collect": True},
-            )
-        ]
-
-    def test_missing_docker_binary_raises_actionable_error(self, monkeypatch):
-        async def fake_subp_exec(*args, **kwargs):
-            raise FileNotFoundError("docker")
-
-        monkeypatch.setattr(deploy_mod, "subp_exec", fake_subp_exec)
-
-        with pytest.raises(click.ClickException, match="Docker is required"):
-            _validate_prebuilt_image(_FakeRunner(), "repo/app:tag", verbose=False)
-
-    def test_missing_image_raises_actionable_error(self, monkeypatch):
-        async def fake_subp_exec(*args, **kwargs):
-            raise click.exceptions.Exit(1)
-
-        monkeypatch.setattr(deploy_mod, "subp_exec", fake_subp_exec)
-
-        with pytest.raises(click.ClickException, match="not found locally"):
-            _validate_prebuilt_image(_FakeRunner(), "missing:tag", verbose=False)
-
-    def test_rejects_non_amd64_platform(self, monkeypatch):
-        async def fake_subp_exec(*args, **kwargs):
-            return "linux/arm64\n", None
-
-        monkeypatch.setattr(deploy_mod, "subp_exec", fake_subp_exec)
-
-        with pytest.raises(click.ClickException, match="requires linux/amd64"):
-            _validate_prebuilt_image(_FakeRunner(), "repo/app:arm", verbose=False)
-
-
 class TestParseEnvFromConfig:
     def test_env_dict(self, tmp_path):
         config_path = tmp_path / "langgraph.json"
@@ -347,6 +284,7 @@ class TestCallHostBackendWithOptionalTenant:
 
     def test_workspace_prompt_blocked_by_no_input(self, monkeypatch):
         """With _no_input=True, 403 requiring workspace should raise ClickException."""
+        import langgraph_cli.deploy as deploy_mod
 
         monkeypatch.setattr(deploy_mod, "_no_input", True)
 
@@ -514,6 +452,7 @@ class TestEmitterTextMode:
 
 class TestCreateHostBackendClientNoInput:
     def test_raises_when_no_api_key_and_no_input(self, monkeypatch, tmp_path):
+        import langgraph_cli.deploy as deploy_mod
 
         monkeypatch.setattr(deploy_mod, "_no_input", True)
         monkeypatch.delenv("LANGSMITH_API_KEY", raising=False)
@@ -528,6 +467,7 @@ class TestCreateHostBackendClientNoInput:
             )
 
     def test_succeeds_with_api_key_in_env(self, monkeypatch, tmp_path):
+        import langgraph_cli.deploy as deploy_mod
 
         monkeypatch.setattr(deploy_mod, "_no_input", True)
         monkeypatch.setenv("LANGSMITH_API_KEY", "lsv2_test")

libs/cli/uv-examples/monorepo/uv.lock

@@ -266,20 +266,20 @@ wheels = [
 
 [[package]]
 name = "langgraph-checkpoint"
-version = "4.2.0"
+version = "4.0.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "langchain-core" },
     { name = "ormsgpack" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/dc/e1/089c4c9e0a2fec7f883f82ae8e6a727138d50074cfeb6644bc2d13b1019b/langgraph_checkpoint-4.2.0.tar.gz", hash = "sha256:51a593b6bee684b0818e5d6e58e28ab340c6db7794575056ce7bd1b746a84ed7", size = 180239, upload-time = "2026-08-07T20:05:03.756Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/b1/44/a8df45d1e8b4637e29789fa8bae1db022c953cc7ac80093cfc52e923547e/langgraph_checkpoint-4.0.1.tar.gz", hash = "sha256:b433123735df11ade28829e40ce25b9be614930cd50245ff2af60629234befd9", size = 158135, upload-time = "2026-02-27T21:06:16.092Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/05/71/3b475f09bd57d3a5649792c66353312b4432afd843f301739dfcebd157f0/langgraph_checkpoint-4.2.0-py3-none-any.whl", hash = "sha256:0547fd228935a0b758865de3a3d6d7a2537c308895d0f9ab092ce9151b5da942", size = 56833, upload-time = "2026-08-07T20:05:02.655Z" },
+    { url = "https://files.pythonhosted.org/packages/65/4c/09a4a0c42f5d2fc38d6c4d67884788eff7fd2cfdf367fdf7033de908b4c0/langgraph_checkpoint-4.0.1-py3-none-any.whl", hash = "sha256:e3adcd7a0e0166f3b48b8cf508ce0ea366e7420b5a73aa81289888727769b034", size = 50453, upload-time = "2026-02-27T21:06:14.293Z" },
 ]
 
 [[package]]
 name = "langgraph-checkpoint-postgres"
-version = "3.1.1"
+version = "3.0.5"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "langgraph-checkpoint" },
@@ -287,9 +287,9 @@ dependencies = [
     { name = "psycopg" },
     { name = "psycopg-pool" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/06/92/1e8959f8cd1b56e672fde3227f6fd642be85af6c5fd662d73921074aa39d/langgraph_checkpoint_postgres-3.1.1.tar.gz", hash = "sha256:d320e147ddad8c374cd546df0b52b532dd54d0541dd9fd23fc738cbd5de76f41", size = 150413, upload-time = "2026-07-30T19:15:39.014Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/95/7a/8f439966643d32111248a225e6cb33a182d07c90de780c4dbfc1e0377832/langgraph_checkpoint_postgres-3.0.5.tar.gz", hash = "sha256:a8fd7278a63f4f849b5cbc7884a15ca8f41e7d5f7467d0a66b31e8c24492f7eb", size = 127856, upload-time = "2026-03-18T21:25:29.785Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/03/32/ba457698a48a0e18d786caa770033067049fbe36d6846f8e50f13b594b51/langgraph_checkpoint_postgres-3.1.1-py3-none-any.whl", hash = "sha256:6e353aecd8150de144fef8e51a49076f58b7d6830d4cf51392b7ad4d79832ba7", size = 50778, upload-time = "2026-07-30T19:15:37.405Z" },
+    { url = "https://files.pythonhosted.org/packages/e8/87/b0f98b33a67204bca9d5619bcd9574222f6b025cf3c125eedcec9a50ecbc/langgraph_checkpoint_postgres-3.0.5-py3-none-any.whl", hash = "sha256:86d7040a88fd70087eaafb72251d796696a0a2d856168f5c11ef620771411552", size = 42907, upload-time = "2026-03-18T21:25:28.75Z" },
 ]
 
 [[package]]

libs/langgraph/langgraph/_internal/_pydantic.py

@@ -68,7 +68,7 @@ def _create_root_model(
 
     def schema(
         cls: type[BaseModel],
-        by_alias: bool = True,
+        by_alias: bool = True,  # noqa: FBT001,FBT002
         ref_template: str = DEFAULT_REF_TEMPLATE,
     ) -> dict[str, Any]:
         # Complains about schema not being defined in superclass
@@ -80,7 +80,7 @@ def _create_root_model(
 
     def model_json_schema(
         cls: type[BaseModel],
-        by_alias: bool = True,
+        by_alias: bool = True,  # noqa: FBT001,FBT002
         ref_template: str = DEFAULT_REF_TEMPLATE,
         schema_generator: type[GenerateJsonSchema] = GenerateJsonSchema,
         mode: JsonSchemaMode = "validation",

libs/langgraph/langgraph/_internal/_runnable.py

@@ -3,7 +3,6 @@ from __future__ import annotations
 import asyncio
 import enum
 import inspect
-import logging
 import sys
 import warnings
 from collections.abc import (
@@ -64,26 +63,6 @@ try:
 except ImportError:
     _StreamingCallbackHandler = None  # type: ignore
 
-logger = logging.getLogger(__name__)
-
-
-def _trace_payload(value: Any, transform: Callable[[Any], Any] | None) -> Any:
-    """Return the payload to record on a run for `value`.
-
-    When `transform` is unset this is a passthrough, so unspecified nodes record exactly
-    as before. When set it always runs (regardless of tracing), but never affects
-    execution: if it raises, the untransformed value is recorded instead.
-    """
-    if transform is None:
-        return value
-    try:
-        return transform(value)
-    except Exception:
-        logger.exception(
-            "trace input/output processor raised; recording untransformed payload"
-        )
-        return value
-
 
 def _set_config_context(
     config: RunnableConfig, run: Any = None
@@ -593,7 +572,6 @@ class RunnableSeq(Runnable):
         *steps: RunnableLike,
         name: str | None = None,
         trace_inputs: Callable[[Any], Any] | None = None,
-        trace_outputs: Callable[[Any], Any] | None = None,
     ) -> None:
         """Create a new RunnableSeq.
 
@@ -619,7 +597,6 @@ class RunnableSeq(Runnable):
         self.steps = steps_flat
         self.name = name
         self.trace_inputs = trace_inputs
-        self.trace_outputs = trace_outputs
 
     def __or__(
         self,
@@ -681,7 +658,7 @@ class RunnableSeq(Runnable):
         # start the root run
         run_manager = callback_manager.on_chain_start(
             None,
-            _trace_payload(input, self.trace_inputs),
+            self.trace_inputs(input) if self.trace_inputs is not None else input,
             name=config.get("run_name") or self.get_name(),
             run_id=config.pop("run_id", None),
         )
@@ -712,7 +689,7 @@ class RunnableSeq(Runnable):
             run_manager.on_chain_error(e)
             raise
         else:
-            run_manager.on_chain_end(_trace_payload(input, self.trace_outputs))
+            run_manager.on_chain_end(input)
             return input
 
     async def ainvoke(
@@ -728,7 +705,7 @@ class RunnableSeq(Runnable):
         # start the root run
         run_manager = await callback_manager.on_chain_start(
             None,
-            _trace_payload(input, self.trace_inputs),
+            self.trace_inputs(input) if self.trace_inputs is not None else input,
             name=config.get("run_name") or self.get_name(),
             run_id=config.pop("run_id", None),
         )
@@ -765,7 +742,7 @@ class RunnableSeq(Runnable):
             await run_manager.on_chain_error(e)
             raise
         else:
-            await run_manager.on_chain_end(_trace_payload(input, self.trace_outputs))
+            await run_manager.on_chain_end(input)
             return input
 
     def stream(
@@ -781,7 +758,7 @@ class RunnableSeq(Runnable):
         # start the root run
         run_manager = callback_manager.on_chain_start(
             None,
-            _trace_payload(input, self.trace_inputs),
+            self.trace_inputs(input) if self.trace_inputs is not None else input,
             name=config.get("run_name") or self.get_name(),
             run_id=config.pop("run_id", None),
         )
@@ -826,7 +803,7 @@ class RunnableSeq(Runnable):
                 run_manager.on_chain_error(e)
                 raise
             else:
-                run_manager.on_chain_end(_trace_payload(output, self.trace_outputs))
+                run_manager.on_chain_end(output)
 
     async def astream(
         self,
@@ -841,7 +818,7 @@ class RunnableSeq(Runnable):
         # start the root run
         run_manager = await callback_manager.on_chain_start(
             None,
-            _trace_payload(input, self.trace_inputs),
+            self.trace_inputs(input) if self.trace_inputs is not None else input,
             name=config.get("run_name") or self.get_name(),
             run_id=config.pop("run_id", None),
         )
@@ -896,9 +873,7 @@ class RunnableSeq(Runnable):
                     await run_manager.on_chain_error(e)
                     raise
                 else:
-                    await run_manager.on_chain_end(
-                        _trace_payload(output, self.trace_outputs)
-                    )
+                    await run_manager.on_chain_end(output)
         else:
             try:
                 async with AsyncExitStack() as stack:
@@ -928,9 +903,7 @@ class RunnableSeq(Runnable):
                 await run_manager.on_chain_error(e)
                 raise
             else:
-                await run_manager.on_chain_end(
-                    _trace_payload(output, self.trace_outputs)
-                )
+                await run_manager.on_chain_end(output)
 
 
 def _consume_iter(it: Iterator[Any]) -> Any:

libs/langgraph/langgraph/_internal/_serde.py

@@ -22,7 +22,7 @@ from pydantic import BaseModel
 from typing_extensions import NotRequired, Required, is_typeddict
 
 try:
-    from langgraph.checkpoint.serde._msgpack import (
+    from langgraph.checkpoint.serde._msgpack import (  # noqa: F401
         STRICT_MSGPACK_ENABLED,
     )
 except ImportError:

libs/langgraph/langgraph/channels/binop.py

@@ -29,25 +29,11 @@ def _strip_extras(t):  # type: ignore[no-untyped-def]
 
 
 def _get_overwrite(value: Any) -> tuple[bool, Any]:
-    """Inspects the given value and returns (is_overwrite, overwrite_value).
-
-    Recognises three forms:
-
-    * The typed `Overwrite` dataclass instance.
-    * The sentinel-keyed `{"__overwrite__": value}` dict form.
-    * The dataclass-erased `{"value": ..., "type": "__overwrite__"}` form that
-      results from JSON-serialising an `Overwrite` (e.g. an `orjson`-encoded
-      state update routed through the LangGraph API server). This keeps the
-      `Overwrite` semantics intact across JSON boundaries that strip dataclass
-      types.
-    """
+    """Inspects the given value and returns (is_overwrite, overwrite_value)."""
     if isinstance(value, Overwrite):
         return True, value.value
-    if isinstance(value, dict):
-        if len(value) == 1 and OVERWRITE in value:
-            return True, value[OVERWRITE]
-        if value.get("type") == OVERWRITE and "value" in value:
-            return True, value["value"]
+    if isinstance(value, dict) and len(value) == 1 and OVERWRITE in value:
+        return True, value[OVERWRITE]
     return False, None
 
 

libs/langgraph/langgraph/channels/delta.py

@@ -172,11 +172,13 @@ class DeltaChannel(Generic[Value], BaseChannel[Any, Any, Any]):
                 overwrite_idx = i
         if overwrite_idx is not None:
             _, overwrite_value = _get_overwrite(values[overwrite_idx])
-            self.value = (
+            base = (
                 _copy.copy(overwrite_value)
                 if overwrite_value is not None
                 else self.typ()
             )
+            remaining = [v for i, v in enumerate(values) if i != overwrite_idx]
+            self.value = self.reducer(base, remaining) if remaining else base
             return True
         base = self.typ() if self.value is MISSING else self.value
         self.value = self.reducer(base, list(values))

libs/langgraph/langgraph/errors.py

@@ -7,7 +7,7 @@ from typing import Any, Literal
 from warnings import warn
 
 # EmptyChannelError is re-exported from langgraph.channels.base
-from langgraph.checkpoint.base import EmptyChannelError
+from langgraph.checkpoint.base import EmptyChannelError  # noqa: F401
 from typing_extensions import deprecated
 
 from langgraph.types import Command, Interrupt

libs/langgraph/langgraph/graph/_node.py

@@ -9,13 +9,7 @@ from langgraph.store.base import BaseStore
 
 from langgraph._internal._typing import EMPTY_SEQ
 from langgraph.runtime import Runtime
-from langgraph.types import (
-    CachePolicy,
-    RetryPolicy,
-    StreamWriter,
-    TimeoutPolicy,
-    TracePolicy,
-)
+from langgraph.types import CachePolicy, RetryPolicy, StreamWriter, TimeoutPolicy
 from langgraph.typing import ContextT, NodeInputT, NodeInputT_contra
 
 
@@ -99,5 +93,3 @@ class StateNodeSpec(Generic[NodeInputT, ContextT]):
     ends: tuple[str, ...] | dict[str, str] | None = EMPTY_SEQ
     defer: bool = False
     timeout: TimeoutPolicy | None = None
-    trace_policy: TracePolicy | None = None
-    """Optional policy controlling what this node records on its trace run."""

libs/langgraph/langgraph/graph/state.py

@@ -85,7 +85,6 @@ from langgraph.types import (
     RetryPolicy,
     Send,
     TimeoutPolicy,
-    TracePolicy,
     ensure_valid_checkpointer,
 )
 from langgraph.typing import ContextT, InputT, NodeInputT, OutputT, StateT
@@ -385,7 +384,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
         error_handler: StateNode[Any, ContextT] | None = None,
         destinations: dict[str, str] | tuple[str, ...] | None = None,
         timeout: float | timedelta | TimeoutPolicy | None = None,
-        trace_policy: TracePolicy | None = None,
         **kwargs: Unpack[DeprecatedKwargs],
     ) -> Self:
         """Add a new node to the `StateGraph`, input schema is inferred as the state schema.
@@ -455,7 +453,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
         error_handler: StateNode[Any, ContextT] | None = None,
         destinations: dict[str, str] | tuple[str, ...] | None = None,
         timeout: float | timedelta | TimeoutPolicy | None = None,
-        trace_policy: TracePolicy | None = None,
         **kwargs: Unpack[DeprecatedKwargs],
     ) -> Self:
         """Add a new node to the `StateGraph` where input schema is specified.
@@ -530,7 +527,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
         error_handler: StateNode[Any, ContextT] | None = None,
         destinations: dict[str, str] | tuple[str, ...] | None = None,
         timeout: float | timedelta | TimeoutPolicy | None = None,
-        trace_policy: TracePolicy | None = None,
         **kwargs: Unpack[DeprecatedKwargs],
     ) -> Self:
         """Add a new node to the `StateGraph`, input schema is inferred as the state schema.
@@ -600,7 +596,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
         error_handler: StateNode[Any, ContextT] | None = None,
         destinations: dict[str, str] | tuple[str, ...] | None = None,
         timeout: float | timedelta | TimeoutPolicy | None = None,
-        trace_policy: TracePolicy | None = None,
         **kwargs: Unpack[DeprecatedKwargs],
     ) -> Self:
         """Add a new node to the `StateGraph`, input schema is specified.
@@ -677,7 +672,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
         error_handler: StateNode[Any, ContextT] | None = None,
         destinations: dict[str, str] | tuple[str, ...] | None = None,
         timeout: float | timedelta | TimeoutPolicy | None = None,
-        trace_policy: TracePolicy | None = None,
         **kwargs: Unpack[DeprecatedKwargs],
     ) -> Self:
         """Add a new node to the `StateGraph`.
@@ -697,10 +691,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
                 If a sequence is provided, the first matching policy will be applied.
             cache_policy: The cache policy for the node.
             error_handler: Optional node-level error handler callable for this node.
-            trace_policy: Optional policy controlling how this node's run is traced. Its
-                `process_inputs` callable transforms the node's input before it is
-                recorded (e.g. to omit or summarize large message history) without
-                changing the value passed to the node. Does not affect execution.
             destinations: Destinations that indicate where a node can route to.
 
                 Useful for edgeless graphs with nodes that return `Command` objects.
@@ -890,7 +880,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
                 ends=ends,
                 defer=defer,
                 timeout=timeout,
-                trace_policy=trace_policy,
             )
         elif inferred_input_schema is not None:
             self.nodes[node] = StateNodeSpec(
@@ -903,7 +892,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
                 ends=ends,
                 defer=defer,
                 timeout=timeout,
-                trace_policy=trace_policy,
             )
         else:
             self.nodes[node] = StateNodeSpec[StateT, ContextT](
@@ -916,7 +904,6 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
                 ends=ends,
                 defer=defer,
                 timeout=timeout,
-                trace_policy=trace_policy,
             )
 
         input_schema = input_schema or inferred_input_schema
@@ -1008,7 +995,7 @@ class StateGraph(Generic[StateT, ContextT, InputT, OutputT]):
             Without type hints on the `path` function's return value (e.g., `-> Literal["foo", "__end__"]:`)
             or a path_map, the graph visualization assumes the edge could transition to any node in the graph.
 
-        """
+        """  # noqa: E501
         if self.compiled:
             logger.warning(
                 "Adding an edge to a graph that has already been compiled. This will "
@@ -1543,7 +1530,6 @@ class CompiledStateGraph(
                 error_handler_node=node.error_handler_node,
                 bound=node.runnable,  # type: ignore[arg-type]
                 timeout=node.timeout,
-                trace_policy=node.trace_policy,
             )
         else:
             raise RuntimeError

libs/langgraph/langgraph/pregel/_checkpoint.py

@@ -1,7 +1,7 @@
 from __future__ import annotations
 
 import uuid
-from collections.abc import Callable, Iterable, Mapping
+from collections.abc import Callable, Mapping
 from datetime import datetime, timezone
 from typing import Any, cast
 
@@ -14,7 +14,6 @@ from langgraph.checkpoint.base.id import uuid6
 from langgraph.checkpoint.serde.types import _DeltaSnapshot
 
 from langgraph._internal._config import DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOT
-from langgraph._internal._constants import PUSH
 from langgraph._internal._typing import MISSING
 from langgraph.channels.base import BaseChannel
 from langgraph.channels.delta import DeltaChannel
@@ -71,81 +70,6 @@ def delta_channels_to_snapshot(
     return result
 
 
-def get_updated_channels_from_tasks(
-    run_tasks: Iterable[Any],
-) -> set[str]:
-    """Channel names written by an update_state superstep (excluding PUSH)."""
-    return {c for task in run_tasks for c, _ in task.writes if c != PUSH}
-
-
-def get_delta_channels_from_all_channels(
-    channels: Mapping[str, BaseChannel],
-) -> set[str]:
-    """DeltaChannels to snapshot on the first update_state of a fresh thread."""
-    return {
-        k
-        for k, ch in channels.items()
-        if isinstance(ch, DeltaChannel) and ch.is_available()
-    }
-
-
-def create_metadata_for_update_state_api(
-    channels: Mapping[str, BaseChannel],
-    updated_channels: set[str],
-    *,
-    prev_metadata: Mapping[str, Any] | None,
-) -> dict[str, tuple[int, int]]:
-    """Advance ``counters_since_delta_snapshot`` for update_state on a non-fresh thread.
-
-    Mirrors the per-superstep counter bump in ``_loop._put_checkpoint``.
-    """
-    prev_counters = dict(
-        (prev_metadata or {}).get("counters_since_delta_snapshot") or {}
-    )
-    new_counters: dict[str, tuple[int, int]] = {}
-    for ch_name, ch in channels.items():
-        if not isinstance(ch, DeltaChannel):
-            continue
-        u, s = prev_counters.get(ch_name, (0, 0))
-        s += 1
-        if ch_name in updated_channels:
-            u += 1
-        new_counters[ch_name] = (u, s)
-    return new_counters
-
-
-def create_checkpoint_plan_for_update_state_api(
-    channels: Mapping[str, BaseChannel],
-    updated_channels: set[str],
-    *,
-    step: int,
-    parents: dict[str, Any],
-    saved_metadata: Mapping[str, Any] | None,
-    is_fresh_thread: bool,
-) -> tuple[set[str], dict[str, Any]]:
-    """Return ``(channels_to_snapshot, metadata)`` for an update_state head."""
-    metadata: dict[str, Any] = {
-        "source": "update",
-        "step": step,
-        "parents": parents,
-    }
-    if is_fresh_thread:
-        return get_delta_channels_from_all_channels(channels), metadata
-
-    new_counters = create_metadata_for_update_state_api(
-        channels,
-        updated_channels,
-        prev_metadata=saved_metadata,
-    )
-    channels_to_snapshot = delta_channels_to_snapshot(channels, new_counters)
-    for k in channels_to_snapshot:
-        new_counters[k] = (0, 0)
-    non_zero = {k: v for k, v in new_counters.items() if v != (0, 0)}
-    if non_zero:
-        metadata["counters_since_delta_snapshot"] = non_zero
-    return channels_to_snapshot, metadata
-
-
 def create_checkpoint(
     checkpoint: Checkpoint,
     channels: Mapping[str, BaseChannel] | None,
@@ -178,11 +102,6 @@ def create_checkpoint(
                 continue
             ch = channels[k]
             if k in channels_to_snapshot:
-                # Callers force a full snapshot blob here: exit mode when a
-                # delta channel reaches its snapshot cadence, and update_state
-                # on a fresh thread (no ancestor to replay writes from). The
-                # manual version-bump below only applies to the exit-mode case.
-                #
                 # In exit mode, the snapshot decision is deferred to exit
                 # time (intermediate steps have do_checkpoint=False). The
                 # channel's count may have reached snapshot_frequency over

libs/langgraph/langgraph/pregel/_loop.py

@@ -70,7 +70,6 @@ from langgraph.callbacks import (
     GraphResumeEvent,
 )
 from langgraph.channels.base import BaseChannel
-from langgraph.channels.binop import _get_overwrite
 from langgraph.channels.delta import DeltaChannel
 from langgraph.channels.untracked_value import UntrackedValue
 from langgraph.constants import TAG_HIDDEN
@@ -222,11 +221,6 @@ class PregelLoop:
     # under the saver's `ORDER BY task_id, idx` sorting.
     _exit_delta_writes: list[tuple[int, str, str, Any]] | None = None
 
-    # Delta channels that saw an Overwrite since the last checkpoint. These
-    # channels must snapshot after live update applies overwrite semantics so
-    # sparse replay starts from the same post-overwrite value.
-    _delta_channels_with_overwrite: set[str]
-
     # The checkpoint_config that points at the parent loaded at `__enter__`
     # (or the synthetic-empty checkpoint, on first run). We capture it
     # eagerly because every `_put_checkpoint` advances `self.checkpoint_config`
@@ -683,11 +677,6 @@ class PregelLoop:
     def after_tick(self) -> None:
         # finish superstep
         writes = [w for t in self.tasks.values() for w in t.writes]
-        self._delta_channels_with_overwrite.update(
-            ch
-            for ch, v in writes
-            if isinstance(self.specs.get(ch), DeltaChannel) and _get_overwrite(v)[0]
-        )
         # all tasks have finished
         self.updated_channels = apply_writes(
             self.checkpoint,
@@ -991,11 +980,6 @@ class PregelLoop:
                 manager=None,
                 updated_channels=updated_channels,
             )
-            self._delta_channels_with_overwrite.update(
-                c
-                for c, v in input_writes
-                if isinstance(self.specs.get(c), DeltaChannel) and _get_overwrite(v)[0]
-            )
             # apply input writes
             updated_channels = apply_writes(
                 self.checkpoint,
@@ -1136,7 +1120,6 @@ class PregelLoop:
         # create new checkpoint
         channels_to_snapshot = (
             delta_channels_to_snapshot(self.channels, new_counters)
-            | self._delta_channels_with_overwrite
             if do_checkpoint
             else set()
         )
@@ -1153,8 +1136,6 @@ class PregelLoop:
         )
         for k in channels_to_snapshot:
             new_counters[k] = (0, 0)
-        if do_checkpoint:
-            self._delta_channels_with_overwrite.difference_update(channels_to_snapshot)
         non_zero = {k: v for k, v in new_counters.items() if v != (0, 0)}
         if non_zero:
             self.checkpoint_metadata["counters_since_delta_snapshot"] = non_zero
@@ -1237,10 +1218,7 @@ class PregelLoop:
         counters = dict(
             self.checkpoint_metadata.get("counters_since_delta_snapshot") or {}
         )
-        channels_to_snapshot = (
-            delta_channels_to_snapshot(self.channels, counters)
-            | self._delta_channels_with_overwrite
-        )
+        channels_to_snapshot = delta_channels_to_snapshot(self.channels, counters)
 
         pending = [
             (step, tid, ch, v)
@@ -1684,7 +1662,6 @@ class SyncPregelLoop(PregelLoop, AbstractContextManager):
         )
         self._delta_write_futs = []
         self._error_handler_write_futs = []
-        self._delta_channels_with_overwrite = set()
         self._exit_delta_writes = (
             [] if self.durability == "exit" and self.checkpointer is not None else None
         )
@@ -1942,7 +1919,6 @@ class AsyncPregelLoop(PregelLoop, AbstractAsyncContextManager):
         )
         self._delta_write_futs = []
         self._error_handler_write_futs = []
-        self._delta_channels_with_overwrite = set()
         self._exit_delta_writes = (
             [] if self.durability == "exit" and self.checkpointer is not None else None
         )

libs/langgraph/langgraph/pregel/_read.py

@@ -16,7 +16,7 @@ from langgraph._internal._timeout import coerce_timeout_policy
 from langgraph.pregel._utils import find_subgraph_pregel
 from langgraph.pregel._write import ChannelWrite
 from langgraph.pregel.protocol import PregelProtocol
-from langgraph.types import CachePolicy, RetryPolicy, TimeoutPolicy, TracePolicy
+from langgraph.types import CachePolicy, RetryPolicy, TimeoutPolicy
 
 READ_TYPE = Callable[[str | Sequence[str], bool], Any | dict[str, Any]]
 INPUT_CACHE_KEY_TYPE = tuple[Callable[..., Any], tuple[str, ...]]
@@ -138,9 +138,6 @@ class PregelNode:
     metadata: Mapping[str, Any] | None
     """Metadata to attach to the node for tracing."""
 
-    trace_policy: TracePolicy | None
-    """Optional policy controlling what this node records on its trace run."""
-
     is_error_handler: bool
     """Whether this node is registered as an error handler node."""
 
@@ -159,7 +156,6 @@ class PregelNode:
         writers: list[Runnable] | None = None,
         tags: list[str] | None = None,
         metadata: Mapping[str, Any] | None = None,
-        trace_policy: TracePolicy | None = None,
         bound: Runnable[Any, Any] | None = None,
         retry_policy: RetryPolicy | Sequence[RetryPolicy] | None = None,
         cache_policy: CachePolicy | None = None,
@@ -181,7 +177,6 @@ class PregelNode:
         self.timeout = coerce_timeout_policy(timeout)
         self.tags = tags
         self.metadata = metadata
-        self.trace_policy = trace_policy
         self.is_error_handler = is_error_handler
         self.error_handler_node = error_handler_node
         if subgraphs is not None:
@@ -227,23 +222,14 @@ class PregelNode:
     def node(self) -> Runnable[Any, Any] | None:
         """Get a runnable that combines `bound` and `writers`."""
         writers = self.flat_writers
-        trace_inputs = self.trace_policy.process_inputs if self.trace_policy else None
-        trace_outputs = self.trace_policy.process_outputs if self.trace_policy else None
         if self.bound is DEFAULT_BOUND and not writers:
             return None
         elif self.bound is DEFAULT_BOUND and len(writers) == 1:
             return writers[0]
         elif self.bound is DEFAULT_BOUND:
-            return RunnableSeq(
-                *writers, trace_inputs=trace_inputs, trace_outputs=trace_outputs
-            )
+            return RunnableSeq(*writers)
         elif writers:
-            return RunnableSeq(
-                self.bound,
-                *writers,
-                trace_inputs=trace_inputs,
-                trace_outputs=trace_outputs,
-            )
+            return RunnableSeq(self.bound, *writers)
         else:
             return self.bound
 

libs/langgraph/langgraph/pregel/_runner.py

@@ -32,10 +32,14 @@ from langgraph._internal._constants import (
     CONFIG_KEY_SCRATCHPAD,
     ERROR,
     ERROR_SOURCE_NODE,
+    INPUT,
     INTERRUPT,
     NO_WRITES,
+    NULL_TASK_ID,
+    PUSH,
     RESUME,
     RETURN,
+    TASKS,
 )
 from langgraph._internal._future import chain_future, run_coroutine_threadsafe
 from langgraph._internal._scratchpad import PregelScratchpad
@@ -585,6 +589,12 @@ class PregelRunner:
             if isinstance(exception, GraphInterrupt):
                 # save interrupt to checkpointer
                 if exception.args[0]:
+                    if pending_writes := _writes_to_persist_on_interrupt(task.writes):
+                        # GraphInterrupt is a controlled suspension point, not a
+                        # task failure. Persist writes emitted before the
+                        # suspension without associating them with task
+                        # completion, so the interrupted task remains resumable.
+                        self.put_writes()(NULL_TASK_ID, pending_writes)  # type: ignore[misc]
                     writes = [(INTERRUPT, exception.args[0])]
                     if resumes := [w for w in task.writes if w[0] == RESUME]:
                         writes.extend(resumes)
@@ -939,3 +949,24 @@ async def _acall_impl(
             destination.set_exception(RuntimeError("Task not scheduled"))
     except Exception as exc:
         destination.set_exception(exc)
+
+
+def _writes_to_persist_on_interrupt(
+    writes: Iterable[tuple[str, Any]],
+) -> list[tuple[str, Any]]:
+    return [
+        write
+        for write in writes
+        if write[0]
+        not in (
+            ERROR,
+            ERROR_SOURCE_NODE,
+            INPUT,
+            INTERRUPT,
+            NO_WRITES,
+            PUSH,
+            RESUME,
+            RETURN,
+            TASKS,
+        )
+    ]

libs/langgraph/langgraph/pregel/_utils.py

@@ -1,10 +1,11 @@
 from __future__ import annotations
 
-import dis
+import ast
+import inspect
 import re
+import textwrap
 from collections.abc import Callable, Sequence
 from functools import partial
-from types import CodeType, FunctionType
 from typing import Any
 
 from langchain_core.runnables import (
@@ -16,6 +17,7 @@ from langchain_core.runnables import (
 from langchain_core.runnables.base import RunnableBindingBase
 from langchain_core.runnables.config import run_in_executor
 from langgraph.checkpoint.base import ChannelVersions
+from typing_extensions import override
 
 from langgraph._internal._runnable import RunnableCallable, RunnableSeq
 from langgraph._internal._timeout import sync_timeout_unsupported
@@ -135,87 +137,155 @@ def validate_timeout_supported(runnable: Runnable, *, name: str) -> None:
         raise sync_timeout_unsupported(name)
 
 
-# Values treated as dead ends when deciding whether to walk a function's
-# bytecode. A container can hold a graph, but `find_subgraph_pregel` does not
-# look inside one, so skipping it costs nothing while that holds. Matched by
-# exact type, since a subclass of a builtin can carry attributes.
-_LEAF_TYPES = frozenset(
-    {
-        int,
-        float,
-        complex,
-        bool,
-        str,
-        bytes,
-        bytearray,
-        list,
-        tuple,
-        dict,
-        set,
-        frozenset,
-        type(None),
-    }
-)
-
-
 def get_function_nonlocals(func: Callable) -> list[Any]:
-    """Get the values a function reaches from outside its own scope.
+    """Get the nonlocal variables accessed by a function.
 
     Args:
         func: The function to check.
 
     Returns:
-        Every captured cell value, the globals the function names, and each
-        value along an attribute path it loads. Over-approximates: a value can
-        come back without the function reaching it at runtime.
+        List[Any]: The nonlocal variables accessed by the function.
     """
-    func = getattr(func, "__func__", func)  # bound method -> function
-    wrapped = getattr(func, "__wrapped__", None)
-    if callable(wrapped):
-        func = getattr(wrapped, "__func__", wrapped)
-    if not isinstance(func, FunctionType):
+    try:
+        code = inspect.getsource(func)
+        tree = ast.parse(textwrap.dedent(code))
+        visitor = FunctionNonLocals()
+        visitor.visit(tree)
+        values: list[Any] = []
+        closure = (
+            inspect.getclosurevars(func.__wrapped__)
+            if hasattr(func, "__wrapped__") and callable(func.__wrapped__)
+            else inspect.getclosurevars(func)
+        )
+        candidates = {**closure.globals, **closure.nonlocals}
+        for k, v in candidates.items():
+            if k in visitor.nonlocals:
+                values.append(v)
+            for kk in visitor.nonlocals:
+                if "." in kk and kk.startswith(k):
+                    vv = v
+                    for part in kk.split(".")[1:]:
+                        if vv is None:
+                            break
+                        else:
+                            try:
+                                vv = getattr(vv, part)
+                            except AttributeError:
+                                break
+                    else:
+                        values.append(vv)
+    except (SyntaxError, TypeError, OSError, SystemError):
         return []
-    code = func.__code__
 
-    cells: dict[str, Any] = {}
-    for name, cell in zip(code.co_freevars, func.__closure__ or ()):
-        try:
-            cells[name] = cell.cell_contents
-        except ValueError:
-            continue  # empty cell: a recursive def not yet bound
-
-    # Every captured value counts, referenced or not: over-declaring costs an
-    # introspection entry, under-declaring drops the subgraph's checkpoints and
-    # stream events. Checking each cell against the bytecode would cost more and
-    # only trade the cheap error for the expensive one.
-    values: list[Any] = list(cells.values())
-    global_ns = func.__globals__
-    globals_ = {name: global_ns[name] for name in code.co_names if name in global_ns}
-    if all(type(v) in _LEAF_TYPES for v in (*cells.values(), *globals_.values())):
-        return values
-
-    # Nested code objects hold the references made by inner defs, lambdas and
-    # comprehensions, which resolve against the namespaces gathered above.
-    codes = [code]
-    for c in codes:
-        codes.extend(k for k in c.co_consts if isinstance(k, CodeType))
-        value: Any = None
-        for instruction in dis.get_instructions(c):
-            opname = instruction.opname
-            if opname == "LOAD_GLOBAL":
-                value = globals_.get(instruction.argval)
-            elif opname == "LOAD_DEREF":
-                value = cells.get(instruction.argval)
-            elif opname in ("LOAD_ATTR", "LOAD_METHOD"):
-                value = getattr(value, instruction.argval, None)
-            else:
-                value = None  # anything else ends the chain: `a, b.c` is not `a.c`
-                continue
-            if value is not None:
-                values.append(value)
     return values
 
 
+class FunctionNonLocals(ast.NodeVisitor):
+    """Get the nonlocal variables accessed of a function."""
+
+    def __init__(self) -> None:
+        self.nonlocals: set[str] = set()
+
+    @override
+    def visit_FunctionDef(self, node: ast.FunctionDef) -> Any:
+        """Visit a function definition.
+
+        Args:
+            node: The node to visit.
+
+        Returns:
+            Any: The result of the visit.
+        """
+        visitor = NonLocals()
+        visitor.visit(node)
+        self.nonlocals.update(visitor.loads - visitor.stores)
+
+    @override
+    def visit_AsyncFunctionDef(self, node: ast.AsyncFunctionDef) -> Any:
+        """Visit an async function definition.
+
+        Args:
+            node: The node to visit.
+
+        Returns:
+            Any: The result of the visit.
+        """
+        visitor = NonLocals()
+        visitor.visit(node)
+        self.nonlocals.update(visitor.loads - visitor.stores)
+
+    @override
+    def visit_Lambda(self, node: ast.Lambda) -> Any:
+        """Visit a lambda function.
+
+        Args:
+            node: The node to visit.
+
+        Returns:
+            Any: The result of the visit.
+        """
+        visitor = NonLocals()
+        visitor.visit(node)
+        self.nonlocals.update(visitor.loads - visitor.stores)
+
+
+class NonLocals(ast.NodeVisitor):
+    """Get nonlocal variables accessed."""
+
+    def __init__(self) -> None:
+        self.loads: set[str] = set()
+        self.stores: set[str] = set()
+
+    @override
+    def visit_Name(self, node: ast.Name) -> Any:
+        """Visit a name node.
+
+        Args:
+            node: The node to visit.
+
+        Returns:
+            Any: The result of the visit.
+        """
+        if isinstance(node.ctx, ast.Load):
+            self.loads.add(node.id)
+        elif isinstance(node.ctx, ast.Store):
+            self.stores.add(node.id)
+
+    @override
+    def visit_Attribute(self, node: ast.Attribute) -> Any:
+        """Visit an attribute node.
+
+        Args:
+            node: The node to visit.
+
+        Returns:
+            Any: The result of the visit.
+        """
+        if isinstance(node.ctx, ast.Load):
+            parent = node.value
+            attr_expr = node.attr
+            while isinstance(parent, ast.Attribute):
+                attr_expr = parent.attr + "." + attr_expr
+                parent = parent.value
+            if isinstance(parent, ast.Name):
+                self.loads.add(parent.id + "." + attr_expr)
+                self.loads.discard(parent.id)
+            elif isinstance(parent, ast.Call):
+                if isinstance(parent.func, ast.Name):
+                    self.loads.add(parent.func.id)
+                else:
+                    parent = parent.func
+                    attr_expr = ""
+                    while isinstance(parent, ast.Attribute):
+                        if attr_expr:
+                            attr_expr = parent.attr + "." + attr_expr
+                        else:
+                            attr_expr = parent.attr
+                        parent = parent.value
+                    if isinstance(parent, ast.Name):
+                        self.loads.add(parent.id + "." + attr_expr)
+
+
 def is_xxh3_128_hexdigest(value: str) -> bool:
     """Check if the given string matches the format of xxh3_128_hexdigest."""
     return bool(re.fullmatch(r"[0-9a-f]{32}", value))

libs/langgraph/langgraph/pregel/main.py

@@ -108,6 +108,7 @@ from langgraph.callbacks import (
     get_sync_graph_callback_manager_for_config,
 )
 from langgraph.channels.base import BaseChannel
+from langgraph.channels.delta import DeltaChannel
 from langgraph.channels.topic import Topic
 from langgraph.config import get_config
 from langgraph.constants import END
@@ -132,9 +133,7 @@ from langgraph.pregel._checkpoint import (
     channels_from_checkpoint,
     copy_checkpoint,
     create_checkpoint,
-    create_checkpoint_plan_for_update_state_api,
     empty_checkpoint,
-    get_updated_channels_from_tasks,
 )
 from langgraph.pregel._draw import draw_graph
 from langgraph.pregel._io import map_input, read_channels
@@ -1997,14 +1996,35 @@ class Pregel(
                         },
                     ),
                 )
-            updated_channels = get_updated_channels_from_tasks(run_tasks)
-            if saved is not None:
-                for task_id, task in zip(run_task_ids, run_tasks):
-                    channel_writes = [w for w in task.writes if w[0] != PUSH]
-                    if channel_writes:
-                        checkpointer.put_writes(
-                            checkpoint_config, channel_writes, task_id
-                        )
+            # save task writes
+            has_delta_writes = any(
+                isinstance(channels.get(c), DeltaChannel)
+                for task in run_tasks
+                for c, _ in task.writes
+            )
+            should_put_writes = saved is not None or has_delta_writes
+
+            if saved is None and has_delta_writes:
+                # If there is no previous checkpoint, we need to create a stub checkpoint
+                # so the first delta writes has a parent to anchor under.
+                # This is the model of DeltaChannel.
+                stub = empty_checkpoint()
+                checkpoint_config = checkpointer.put(
+                    patch_configurable(
+                        checkpoint_config, {CONFIG_KEY_CHECKPOINT_ID: None}
+                    ),
+                    stub,
+                    {"source": "update", "step": -1, "parents": {}},
+                    {},
+                )
+
+            for task_id, task in zip(run_task_ids, run_tasks):
+                # channel writes are saved to current checkpoint
+                channel_writes = [w for w in task.writes if w[0] != PUSH]
+                if should_put_writes and channel_writes:
+                    checkpointer.put_writes(checkpoint_config, channel_writes, task_id)
+
+            # apply to checkpoint and save
             apply_writes(
                 checkpoint,
                 channels,
@@ -2012,35 +2032,21 @@ class Pregel(
                 checkpointer.get_next_version,
                 self.trigger_to_nodes,
             )
-            channels_to_snapshot, checkpoint_metadata = (
-                create_checkpoint_plan_for_update_state_api(
-                    channels,
-                    updated_channels,
-                    step=step + 1,
-                    parents=saved.metadata.get("parents", {}) if saved else {},
-                    saved_metadata=saved.metadata if saved else None,
-                    is_fresh_thread=saved is None,
-                )
-            )
-            checkpoint = create_checkpoint(
-                checkpoint,
-                channels,
-                step + 1,
-                updated_channels=updated_channels if channels_to_snapshot else None,
-                get_next_version=checkpointer.get_next_version
-                if channels_to_snapshot
-                else None,
-                channels_to_snapshot=channels_to_snapshot,
-            )
+            checkpoint = create_checkpoint(checkpoint, channels, step + 1)
             next_config = checkpointer.put(
                 checkpoint_config,
                 checkpoint,
-                checkpoint_metadata,
+                {
+                    "source": "update",
+                    "step": step + 1,
+                    "parents": saved.metadata.get("parents", {}) if saved else {},
+                },
                 get_new_channel_versions(
                     checkpoint_previous_versions, checkpoint["channel_versions"]
                 ),
             )
             for task_id, task in zip(run_task_ids, run_tasks):
+                # save push writes
                 if push_writes := [w for w in task.writes if w[0] == PUSH]:
                     checkpointer.put_writes(next_config, push_writes, task_id)
 
@@ -2457,14 +2463,36 @@ class Pregel(
                         },
                     ),
                 )
-            updated_channels = get_updated_channels_from_tasks(run_tasks)
-            if saved is not None:
-                for task_id, task in zip(run_task_ids, run_tasks):
-                    channel_writes = [w for w in task.writes if w[0] != PUSH]
-                    if channel_writes:
-                        await checkpointer.aput_writes(
-                            checkpoint_config, channel_writes, task_id
-                        )
+            # save task writes
+            has_delta_writes = any(
+                isinstance(channels.get(c), DeltaChannel)
+                for task in run_tasks
+                for c, _ in task.writes
+            )
+            should_put_writes = saved is not None or has_delta_writes
+
+            if saved is None and has_delta_writes:
+                # If there is no previous checkpoint, we need to create a stub checkpoint
+                # so the first delta writes has a parent to anchor under.
+                # This is the model of DeltaChannel.
+                stub = empty_checkpoint()
+                checkpoint_config = await checkpointer.aput(
+                    patch_configurable(
+                        checkpoint_config, {CONFIG_KEY_CHECKPOINT_ID: None}
+                    ),
+                    stub,
+                    {"source": "update", "step": -1, "parents": {}},
+                    {},
+                )
+
+            for task_id, task in zip(run_task_ids, run_tasks):
+                # channel writes are saved to current checkpoint
+                channel_writes = [w for w in task.writes if w[0] != PUSH]
+                if should_put_writes and channel_writes:
+                    await checkpointer.aput_writes(
+                        checkpoint_config, channel_writes, task_id
+                    )
+            # apply to checkpoint and save
             apply_writes(
                 checkpoint,
                 channels,
@@ -2472,35 +2500,22 @@ class Pregel(
                 checkpointer.get_next_version,
                 self.trigger_to_nodes,
             )
-            channels_to_snapshot, checkpoint_metadata = (
-                create_checkpoint_plan_for_update_state_api(
-                    channels,
-                    updated_channels,
-                    step=step + 1,
-                    parents=saved.metadata.get("parents", {}) if saved else {},
-                    saved_metadata=saved.metadata if saved else None,
-                    is_fresh_thread=saved is None,
-                )
-            )
-            checkpoint = create_checkpoint(
-                checkpoint,
-                channels,
-                step + 1,
-                updated_channels=updated_channels if channels_to_snapshot else None,
-                get_next_version=checkpointer.get_next_version
-                if channels_to_snapshot
-                else None,
-                channels_to_snapshot=channels_to_snapshot,
-            )
+            checkpoint = create_checkpoint(checkpoint, channels, step + 1)
+            # save checkpoint, after applying writes
             next_config = await checkpointer.aput(
                 checkpoint_config,
                 checkpoint,
-                checkpoint_metadata,
+                {
+                    "source": "update",
+                    "step": step + 1,
+                    "parents": saved.metadata.get("parents", {}) if saved else {},
+                },
                 get_new_channel_versions(
                     checkpoint_previous_versions, checkpoint["channel_versions"]
                 ),
             )
             for task_id, task in zip(run_task_ids, run_tasks):
+                # save push writes
                 if push_writes := [w for w in task.writes if w[0] == PUSH]:
                     await checkpointer.aput_writes(next_config, push_writes, task_id)
             return patch_checkpoint_map(next_config, saved.metadata if saved else None)
@@ -3512,7 +3527,7 @@ class Pregel(
         control: RunControl | None = None,
         transformers: Sequence[Callable[[tuple[str, ...]], Any]] | None = None,
         **kwargs: Any,
-    ) -> GraphRunStream:
+    ) -> Any:
         """Internal v3 sync streaming implementation. Public entry: stream_events(version='v3').
 
         Extra keyword arguments are forwarded to the underlying ``stream(...)``
@@ -3568,7 +3583,7 @@ class Pregel(
         control: RunControl | None = None,
         transformers: Sequence[Callable[[tuple[str, ...]], Any]] | None = None,
         **kwargs: Any,
-    ) -> AsyncGraphRunStream:
+    ) -> Any:
         """Internal v3 async streaming implementation. Public entry: astream_events(version='v3').
 
         Extra keyword arguments are forwarded to the underlying ``astream(...)``
@@ -3633,7 +3648,7 @@ class Pregel(
         control: RunControl | None = None,
         transformers: Sequence[Callable[[tuple[str, ...]], Any]] | None = None,
         **kwargs: Any,
-    ) -> GraphRunStream: ...
+    ) -> Any: ...
 
     def stream_events(
         self,
@@ -3738,7 +3753,7 @@ class Pregel(
         control: RunControl | None = None,
         transformers: Sequence[Callable[[tuple[str, ...]], Any]] | None = None,
         **kwargs: Any,
-    ) -> Awaitable[AsyncGraphRunStream]: ...
+    ) -> Awaitable[Any]: ...
 
     def astream_events(
         self,

libs/langgraph/langgraph/pregel/protocol.py

@@ -2,7 +2,7 @@ from __future__ import annotations
 
 from abc import abstractmethod
 from collections.abc import AsyncIterator, Callable, Iterator, Sequence
-from typing import Any, Generic, Literal, overload
+from typing import Any, Generic, Literal, cast, overload
 
 from langchain_core.runnables import Runnable, RunnableConfig
 from langchain_core.runnables.graph import Graph as DrawableGraph
@@ -277,12 +277,12 @@ class StreamProtocol:
 
     modes: set[StreamMode]
 
-    __call__: Callable[[StreamChunk], None]
+    __call__: Callable[[Self, StreamChunk], None]
 
     def __init__(
         self,
         __call__: Callable[[StreamChunk], None],
         modes: set[StreamMode],
     ) -> None:
-        self.__call__ = __call__
+        self.__call__ = cast(Callable[[Self, StreamChunk], None], __call__)
         self.modes = modes

libs/langgraph/langgraph/stream/run_stream.py

@@ -3,7 +3,7 @@ from __future__ import annotations
 import asyncio
 from collections.abc import AsyncIterator, Awaitable, Callable, Iterator, Mapping
 from types import MappingProxyType, TracebackType
-from typing import TYPE_CHECKING, Any, NoReturn
+from typing import TYPE_CHECKING, Any
 
 from langchain_core._api import beta
 
@@ -12,13 +12,7 @@ from langgraph.stream._mux import StreamMux
 from langgraph.stream._types import ProtocolEvent
 
 if TYPE_CHECKING:
-    from langchain_core.language_models.chat_model_stream import (
-        AsyncChatModelStream,
-        ChatModelStream,
-    )
-
-    from langgraph.stream.stream_channel import StreamChannel
-    from langgraph.stream.transformers import LifecyclePayload, SubgraphStatus
+    from langgraph.stream.transformers import SubgraphStatus
 
 
 def _drive_until_done(pump: Callable[[], bool]) -> None:
@@ -33,26 +27,6 @@ async def _adrive_until_done(pump: Callable[[], Awaitable[bool]]) -> None:
         pass
 
 
-def _raise_missing_projection(run: object, name: str) -> NoReturn:
-    """Raise after normal attribute lookup fails for a projection.
-
-    Registered native projections are installed directly on the run instance
-    during `__init__`, so `__getattr__` is never called for them. At this point
-    the requested name is necessarily missing; the mux is inspected only to
-    include the valid registered projection names in the error message.
-
-    Read `_mux` directly from `__dict__` because it may not exist yet on a
-    partially initialized instance. Accessing `run._mux` in that case would
-    invoke `__getattr__` again and recurse indefinitely.
-    """
-    mux = run.__dict__.get("_mux")
-    registered = sorted(mux.native_keys) if mux is not None else []
-    raise AttributeError(
-        f"{type(run).__name__!r} object has no attribute {name!r} "
-        f"(registered projections: {', '.join(registered) or 'none'})"
-    )
-
-
 @beta(message="The v3 streaming protocol on Pregel is experimental.")
 class GraphRunStream:
     """Sync run stream with caller-driven pumping.
@@ -74,33 +48,6 @@ class GraphRunStream:
         experimental and may change.
     """
 
-    # Native projections, attached dynamically by the `setattr` loop in
-    # `__init__` and declared here so type checkers see them.
-    #
-    # Always registered by `stream_events(version="v3")`:
-    values: StreamChannel[dict[str, Any]]
-    messages: StreamChannel[ChatModelStream]
-    lifecycle: StreamChannel[LifecyclePayload]
-    subgraphs: StreamChannel[SubgraphRunStream]
-    # Registered on demand via `compile(transformers=...)` or
-    # `stream_events(transformers=...)`; reading one whose transformer was not
-    # registered raises AttributeError. Projections contributed by transformers
-    # outside this package are covered by `__getattr__` instead.
-    updates: StreamChannel[dict[str, Any]]
-    custom: StreamChannel[Any]
-    checkpoints: StreamChannel[dict[str, Any]]
-    debug: StreamChannel[dict[str, Any]]
-    tasks: StreamChannel[dict[str, Any]]
-
-    def __getattr__(self, name: str) -> StreamChannel[Any]:
-        """Type the projections of transformers declared outside this package.
-
-        Projection names come from a registry, so no annotation here can name
-        them all. The cost is that a misspelling type-checks too, and fails at
-        runtime instead.
-        """
-        _raise_missing_projection(self, name)
-
     def __init__(
         self,
         graph_iter: Iterator[Any] | None,
@@ -382,25 +329,6 @@ class AsyncGraphRunStream:
         experimental and may change.
     """
 
-    # Native projections, attached dynamically by the `setattr` loop in
-    # `__init__` and declared here so type checkers see them.
-    #
-    # Always registered by `astream_events(version="v3")`:
-    values: StreamChannel[dict[str, Any]]
-    messages: StreamChannel[AsyncChatModelStream]
-    lifecycle: StreamChannel[LifecyclePayload]
-    subgraphs: StreamChannel[AsyncSubgraphRunStream]
-    # Registered on demand; see `GraphRunStream`.
-    updates: StreamChannel[dict[str, Any]]
-    custom: StreamChannel[Any]
-    checkpoints: StreamChannel[dict[str, Any]]
-    debug: StreamChannel[dict[str, Any]]
-    tasks: StreamChannel[dict[str, Any]]
-
-    def __getattr__(self, name: str) -> StreamChannel[Any]:
-        """Type projections declared elsewhere. See `GraphRunStream`."""
-        _raise_missing_projection(self, name)
-
     def __init__(
         self,
         graph_aiter: AsyncIterator[Any] | None,

libs/langgraph/langgraph/types.py

@@ -70,8 +70,6 @@ __all__ = (
     "RetryPolicy",
     "TimeoutPolicy",
     "CachePolicy",
-    "TracePolicy",
-    "omit_payload",
     "Interrupt",
     "StateUpdate",
     "PregelTask",
@@ -529,44 +527,6 @@ class CachePolicy(Generic[KeyFuncT]):
     """Time to live for the cache entry in seconds. If `None`, the entry never expires."""
 
 
-@dataclass(**_DC_KWARGS)
-class TracePolicy:
-    """Configuration for how a node's run is traced.
-
-    Scope: this only transforms what the node's *own* run records. Child runs created
-    by a traced `bound` runnable and the root graph run are not affected. Plain
-    function nodes are traced with `trace=False`, so they have no such child runs.
-
-    Not intended to redact secrets. To redact inputs/outputs across all runs
-    (children included), use the LangSmith client's
-    `hide_inputs`/`hide_outputs`/`anonymizer` instead.
-
-    Each processor receives the node's raw input/output value (not a normalized
-    kwargs dict) and returns the value to record.
-    """
-
-    process_inputs: Callable[[Any], Any] | None = None
-    """Optional callable to transform the node's input before it is recorded on the
-    node's trace run. Can be used to omit or summarize large payloads
-    (e.g. message history). Not intended to affect the value passed to the node; avoid
-    mutating arguments in place."""
-
-    process_outputs: Callable[[Any], Any] | None = None
-    """Optional callable to transform the node's output before it is recorded on the
-    node's trace run. Can be used to omit or summarize large payloads
-    (e.g. message history). Not intended to affect the value returned by the node; avoid
-    mutating arguments in place."""
-
-
-def omit_payload(_value: Any) -> dict[str, Any]:
-    """`TracePolicy` helper that records an empty payload, dropping the value entirely.
-
-    Use as `process_inputs` and/or `process_outputs` on a `TracePolicy` to keep a node's
-    span and its timing while omitting its inputs/outputs from the trace.
-    """
-    return {}
-
-
 _DEFAULT_INTERRUPT_ID = "placeholder-id"
 
 
@@ -1016,9 +976,3 @@ class Overwrite:
 
     value: Any
     """The value to write directly to the channel, bypassing any reducer."""
-
-    type: Literal["__overwrite__"] = "__overwrite__"
-    """Discriminator field. Lets the channel reducer recognise an `Overwrite`
-    even after its dataclass form is JSON-serialised and the typed instance
-    is lost (e.g. an `orjson`-encoded state update routed through the
-    LangGraph API server)."""

libs/langgraph/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "langgraph"
-version = "1.2.11"
+version = "1.2.6"
 description = "Building stateful, multi-actor applications with LLMs"
 authors = []
 requires-python = ">=3.10"
@@ -89,12 +89,8 @@ langgraph-sdk = { path = "../sdk-py", editable = true }
 langgraph-cli = { path = "../cli", editable = true }
 
 [tool.ruff]
-lint.select = [ "E", "F", "I", "PLC0415", "RUF100", "TID251", "UP" ]
+lint.select = [ "E", "F", "I", "TID251", "UP" ]
 lint.ignore = [ "E501" ]
-# PLC0415 (import-outside-top-level) is enforced in tests only. Library code
-# still has deferred imports that have not been reviewed, so it stays exempt
-# for now.
-lint.per-file-ignores = { "langgraph/**" = ["PLC0415"] }
 line-length = 88
 indent-width = 4
 extend-include = ["*.ipynb"]

libs/langgraph/tests/memory_assert.py

@@ -1,6 +1,5 @@
 import os
 import tempfile
-import time
 from collections import defaultdict
 from functools import partial
 from typing import Any
@@ -74,6 +73,8 @@ class MemorySaverAssertImmutable(InMemorySaver):
         new_versions: ChannelVersions,
     ) -> None:
         if self.put_sleep:
+            import time
+
             time.sleep(self.put_sleep)
         # assert checkpoint hasn't been modified since last written
         thread_id = config["configurable"]["thread_id"]

libs/langgraph/tests/test_channels.py

@@ -2,16 +2,14 @@ import operator
 from collections.abc import Sequence
 from typing import Annotated
 
-import orjson
 import pytest
 from langchain_core.messages import AIMessage, HumanMessage, RemoveMessage
 from langgraph.checkpoint.memory import InMemorySaver
 from langgraph.checkpoint.serde.types import _DeltaSnapshot
 from typing_extensions import NotRequired, TypedDict
 
-from langgraph._internal._constants import OVERWRITE
 from langgraph._internal._typing import MISSING
-from langgraph.channels.binop import BinaryOperatorAggregate, _get_overwrite
+from langgraph.channels.binop import BinaryOperatorAggregate
 from langgraph.channels.delta import DeltaChannel
 from langgraph.channels.last_value import LastValue
 from langgraph.channels.topic import Topic
@@ -188,43 +186,6 @@ def test_delta_channel_overwrite() -> None:
     assert ch.get()[0].content == "new"
 
 
-def test_overwrite_dataclass_form_survives_json_roundtrip() -> None:
-    """`Overwrite` serialised with `orjson` collapses to a plain dict but
-    must still be recognised as an overwrite by the channel reducer.
-
-    Without the `type` discriminator the dataclass-erased shape (`{"value":
-    ...}`) is indistinguishable from a literal channel value, and downstream
-    reducers raise `MESSAGE_COERCION_FAILURE` (or similar) on read.
-    """
-
-    ow = Overwrite(value=[HumanMessage(content="new", id="h2")])
-    erased = orjson.loads(orjson.dumps(ow, default=lambda o: o.model_dump()))
-
-    assert erased["type"] == OVERWRITE
-    is_overwrite, value = _get_overwrite(erased)
-    assert is_overwrite
-    assert isinstance(value, list)
-    assert value[0]["content"] == "new"
-
-
-def test_overwrite_sentinel_dict_still_recognised() -> None:
-    """The pre-existing `{"__overwrite__": value}` dict form continues to be
-    recognised. This is the canonical sentinel emitted by producers that do
-    not have an `Overwrite` dataclass available."""
-
-    is_overwrite, value = _get_overwrite({OVERWRITE: ["b"]})
-    assert is_overwrite
-    assert value == ["b"]
-
-
-def test_overwrite_non_matching_dict_not_recognised() -> None:
-    """Dicts that resemble the erased shape but do not carry the
-    `__overwrite__` discriminator must not be misclassified as overwrites."""
-
-    assert _get_overwrite({"value": ["b"]}) == (False, None)
-    assert _get_overwrite({"type": "human", "value": "hi"}) == (False, None)
-
-
 def test_delta_channel_remove_message_and_replay() -> None:
     """RemoveMessage must round-trip correctly when writes are replayed."""
     spec = DeltaChannel(_messages_delta_reducer, list)
@@ -436,93 +397,6 @@ def test_delta_channel_inmemory_saver_assembles_writes() -> None:
     assert len(state.values["messages"]) == 4  # 2 human + 2 AI
 
 
-def test_delta_channel_overwrite_superstep_snapshots() -> None:
-    def reducer(state: list[str], writes: Sequence[list[str]]) -> list[str]:
-        result = list(state)
-        for write in writes:
-            result.extend(write)
-        return result
-
-    class State(TypedDict):
-        items: Annotated[
-            list[str], DeltaChannel(reducer, list, snapshot_frequency=1000)
-        ]
-
-    def node_a(state: State) -> dict:
-        return {"items": ["a"]}
-
-    def node_b(state: State) -> dict:
-        return {"items": Overwrite(["b"])}
-
-    def node_c(state: State) -> dict:
-        return {"items": ["c"]}
-
-    builder = StateGraph(State)
-    builder.add_node("node_a", node_a)
-    builder.add_node("node_b", node_b)
-    builder.add_node("node_c", node_c)
-    builder.add_edge(START, "node_a")
-    builder.add_edge("node_a", "node_b")
-    builder.add_edge("node_a", "node_c")
-
-    saver = InMemorySaver()
-    graph = builder.compile(checkpointer=saver)
-    config = {"configurable": {"thread_id": "overwrite-snapshot"}}
-
-    result = graph.invoke({"items": ["START"]}, config)
-    assert result == {"items": ["b"]}
-
-    saved = saver.get_tuple(config)
-    assert saved is not None
-    snapshot = saved.checkpoint["channel_values"].get("items")
-    assert isinstance(snapshot, _DeltaSnapshot)
-    assert snapshot.value == ["b"]
-    assert saved.metadata.get("counters_since_delta_snapshot", {}).get("items") is None
-
-
-def test_delta_channel_replay_after_overwrite_snapshot() -> None:
-    def reducer(state: list[str], writes: Sequence[list[str]]) -> list[str]:
-        result = list(state)
-        for write in writes:
-            result.extend(write)
-        return result
-
-    class State(TypedDict):
-        items: Annotated[
-            list[str], DeltaChannel(reducer, list, snapshot_frequency=1000)
-        ]
-
-    calls = 0
-
-    def node(state: State) -> dict:
-        nonlocal calls
-        calls += 1
-        if calls == 1:
-            return {"items": Overwrite(["reset"])}
-        return {"items": ["after"]}
-
-    builder = StateGraph(State)
-    builder.add_node("node", node)
-    builder.add_edge(START, "node")
-
-    saver = InMemorySaver()
-    graph = builder.compile(checkpointer=saver)
-    config = {"configurable": {"thread_id": "overwrite-replay"}}
-
-    assert graph.invoke({"items": ["before"]}, config) == {"items": ["reset"]}
-    first_saved = saver.get_tuple(config)
-    assert first_saved is not None
-    assert isinstance(
-        first_saved.checkpoint["channel_values"].get("items"), _DeltaSnapshot
-    )
-
-    assert graph.invoke({"items": []}, config) == {"items": ["reset", "after"]}
-    second_saved = saver.get_tuple(config)
-    assert second_saved is not None
-    assert "items" not in second_saved.checkpoint["channel_values"]
-    assert graph.get_state(config).values == {"items": ["reset", "after"]}
-
-
 # ---------------------------------------------------------------------------
 # DeltaChannel — dict reducer
 # ---------------------------------------------------------------------------

libs/langgraph/tests/test_config_async.py

@@ -24,7 +24,7 @@ class _TrackingCallback(BaseCallbackHandler):
     def __init__(self) -> None:
         self.called = False
 
-    def on_chain_start(self, *args, **kwargs) -> None:
+    def on_chain_start(self, *args, **kwargs) -> None:  # noqa: ANN002, ANN003
         self.called = True
 
 
@@ -55,7 +55,7 @@ async def test_with_config_configurable_preserved_on_invoke() -> None:
     builder = StateGraph(dict)
     captured: dict = {}
 
-    def node(state, config):
+    def node(state, config):  # noqa: ANN001
         captured.update(config.get("configurable") or {})
         return state
 
@@ -79,7 +79,7 @@ async def test_with_config_metadata_preserved_on_invoke() -> None:
     builder = StateGraph(dict)
     captured: dict = {}
 
-    def node(state, config):
+    def node(state, config):  # noqa: ANN001
         captured.update(config.get("metadata") or {})
         return state
 
@@ -104,7 +104,7 @@ async def test_with_config_tags_preserved_on_invoke() -> None:
     builder = StateGraph(dict)
     captured: list = []
 
-    def node(state, config):
+    def node(state, config):  # noqa: ANN001
         captured.extend(config.get("tags") or [])
         return state
 

libs/langgraph/tests/test_delta_channel_benchmark.py

@@ -220,7 +220,7 @@ def _checkpointers() -> list[tuple[str, Any]]:
     result: list[tuple[str, Any]] = [("InMemory", None)]
     if _POSTGRES_AVAILABLE:
         try:
-            import psycopg  # noqa: PLC0415
+            import psycopg
 
             psycopg.connect(_POSTGRES_URI).close()
             result.append(("Postgres", "postgres"))

libs/langgraph/tests/test_delta_channel_migration.py

@@ -616,117 +616,3 @@ async def test_add_messages_to_delta_migration_preserves_message_history_async()
     assert [m.id for m in snap.values["messages"]] == ["h1", "a1"], (
         f"async tip hydration mismatch: got {[m.id for m in snap.values['messages']]}"
     )
-
-
-# ---------------------------------------------------------------------------
-# 8. First post-migration write, read back cold (regression for #8384)
-#
-# The migration boundary produces a checkpoint that carries BOTH a pre-delta
-# plain-value blob AND the pending write that produced its (delta-era) child.
-# That write is not subsumed by the blob — the blob is the value ENTERING that
-# checkpoint. A saver whose ancestor walk skips the seed checkpoint's own
-# writes silently drops the first post-migration write.
-#
-# The failure is invisible to the live `invoke` return value (computed
-# in-memory before persistence), so these tests must assert on a COLD read.
-# It is also invisible at `snapshot_frequency=1`, where every write is its own
-# snapshot boundary and the walk never terminates on a plain value — hence the
-# explicit default-frequency coverage.
-# ---------------------------------------------------------------------------
-
-
-def test_first_post_migration_write_survives_cold_read() -> None:
-    """One non-snapshotting write after migrating a thread to `DeltaChannel`
-    must still be present when the state is read back from the checkpointer.
-
-    Regression for #8384: `invoke` returned the correct value while
-    `get_state` dropped the write permanently.
-    """
-
-    checkpointer = InMemorySaver()
-    config = {"configurable": {"thread_id": "first-post-migration"}}
-
-    binop = _binop_graph(checkpointer)
-    binop.invoke({"items": ["a"]}, config)
-
-    delta = _delta_graph(checkpointer)
-    live = delta.invoke({"items": ["b"]}, config)
-    assert list(live["items"]) == ["a", "b"], "live invoke lost the write"
-
-    cold = delta.get_state(config)
-    assert list(cold.values["items"]) == ["a", "b"], (
-        "first post-migration write dropped on cold read: "
-        f"got {list(cold.values['items'])}"
-    )
-
-
-async def test_first_post_migration_write_survives_cold_read_async() -> None:
-    """Async variant of the #8384 regression."""
-
-    checkpointer = InMemorySaver()
-    config = {"configurable": {"thread_id": "first-post-migration-async"}}
-
-    binop = _binop_graph(checkpointer)
-    await binop.ainvoke({"items": ["a"]}, config)
-
-    delta = _delta_graph(checkpointer)
-    live = await delta.ainvoke({"items": ["b"]}, config)
-    assert list(live["items"]) == ["a", "b"], "live ainvoke lost the write"
-
-    cold = await delta.aget_state(config)
-    assert list(cold.values["items"]) == ["a", "b"], (
-        "first post-migration write dropped on cold read: "
-        f"got {list(cold.values['items'])}"
-    )
-
-
-def test_post_migration_writes_match_base_saver_fallback() -> None:
-    """Parity across the migration boundary WITH post-migration writes.
-
-    `test_base_saver_fallback_matches_optimized_override` only reads a
-    pre-migration chain, so the optimized override and the reference walk
-    never disagree there. Driving writes after the migration is what
-    separates them.
-    """
-
-    def _run(saver: Any, thread: str) -> list[tuple[Any, list]]:
-        config = {"configurable": {"thread_id": thread}}
-        _drive(_binop_graph(saver), config, "u", 2)
-        delta = _delta_graph(saver)
-        _drive(delta, config, "d", 3)
-        return [
-            (s.next, list(s.values.get("items", [])))
-            for s in delta.get_state_history(config)
-        ]
-
-    fast = _run(InMemorySaver(), "fast")
-    slow = _run(_ThirdPartyStyleSaver(), "slow")
-
-    assert fast == slow, (
-        "optimized override diverges from the base-saver fallback once "
-        f"post-migration writes exist; fast={fast}, slow={slow}"
-    )
-    # Guard the assertion above against both paths being wrong in the same way.
-    assert fast[0][1] == ["u0", "u1", "d0", "d1", "d2"], (
-        f"unexpected accumulated state: {fast[0][1]}"
-    )
-
-
-def test_add_messages_migration_keeps_first_post_migration_message() -> None:
-    """The `add_messages` -> `DeltaChannel` path is the one Deep Agents takes;
-    dropping the first post-migration write loses a real user message.
-    """
-
-    checkpointer = InMemorySaver()
-    config = {"configurable": {"thread_id": "add-messages-first-write"}}
-
-    pre_graph = _add_messages_graph(checkpointer)
-    pre_graph.invoke({"messages": [HumanMessage(content="hello", id="h1")]}, config)
-
-    delta_graph = _delta_messages_graph(checkpointer)
-    delta_graph.invoke({"messages": [HumanMessage(content="second", id="h2")]}, config)
-
-    ids = [m.id for m in delta_graph.get_state(config).values["messages"]]
-    # h1 is the pre-migration seed, h2 the write that was being dropped; both
-    # have to survive, and in order.
-    assert ids == ["h1", "h2"], f"expected ['h1', 'h2'], got {ids}"

libs/langgraph/tests/test_delta_channel_update_state.py

@@ -1,19 +1,20 @@
 """Tests for `update_state` / `aupdate_state` against `DeltaChannel`.
 
-Regression suite for deepagents#3774 and Postgres read-path compatibility.
-
-Fresh-thread ``update_state`` force-snapshots DeltaChannels (1.2.8). Non-fresh
-``update_state`` persists ``checkpoint_writes`` on the parent, advances
-``counters_since_delta_snapshot`` on the new head, and snapshots when a
-channel reaches ``snapshot_frequency`` (mirroring normal run cadence).
+Originally a regression suite for deepagents#3774 — `update_state` on a *fresh*
+thread silently dropped the first write to a `DeltaChannel`-backed channel
+because channel writes were only persisted when a previous checkpoint existed.
+Fixed by lazily persisting an empty stub checkpoint on a fresh thread so the
+first write has a parent to anchor under (mirrors the exit-mode lazy-stub
+pattern in `_loop._put_exit_delta_writes`).
 
 Coverage:
 
-* fresh-thread regression: single ``update_state`` writes a message and reads back
-* non-fresh thread: ``update_state`` after ``invoke``, after another ``update_state``,
-  and ``bulk_update_state`` with multiple per-superstep updates
-* update-by-id end-to-end via ``update_state`` (DeltaChannel reducer semantics)
-* fresh-thread head is snapshotted; non-fresh heads carry delta replay counters
+* fresh-thread regression: single `update_state` writes a message and reads back
+* non-fresh thread: `update_state` after `invoke`, after another `update_state`,
+  and `bulk_update_state` with multiple per-superstep updates
+* update-by-id end-to-end via `update_state` (DeltaChannel reducer semantics)
+* state-history chain shape on a fresh thread (lazy stub + update checkpoint
+  with correct parent linking)
 """
 
 from typing import Annotated, Any
@@ -21,31 +22,22 @@ from typing import Annotated, Any
 import pytest
 from langchain_core.messages import HumanMessage
 from langgraph.checkpoint.memory import InMemorySaver
-from langgraph.checkpoint.serde.types import _DeltaSnapshot
 from typing_extensions import TypedDict
 
 from langgraph.channels.delta import DeltaChannel
 from langgraph.graph import START, StateGraph
 from langgraph.graph.message import _messages_delta_reducer
-from langgraph.types import StateUpdate
 
 pytestmark = pytest.mark.anyio
 
 
-def _build_graph(
-    checkpointer: InMemorySaver,
-    *,
-    two_nodes: bool = False,
-    snapshot_frequency: int = 1000,
-) -> Any:
+def _build_graph(checkpointer: InMemorySaver, *, two_nodes: bool = False) -> Any:
     """Compile a minimal DeltaChannel-backed `messages` graph.
 
     `two_nodes=True` adds a second writer node so `bulk_update_state` can route
     distinct updates to different `as_node` values within a single superstep.
     """
-    channel = DeltaChannel(
-        _messages_delta_reducer, snapshot_frequency=snapshot_frequency
-    )
+    channel = DeltaChannel(_messages_delta_reducer)
     State = TypedDict("State", {"messages": Annotated[list, channel]})  # type: ignore[call-overload]  # noqa: UP013
 
     def model(state: dict) -> dict:
@@ -95,30 +87,14 @@ async def test_aupdate_state_fresh_thread_delta_channel() -> None:
     assert [m.content for m in state.values["messages"]] == ["hello"]
 
 
-def test_fresh_update_state_head_snapshots_delta_channel() -> None:
-    saver = InMemorySaver()
-    graph = _build_graph(saver)
-    config = {"configurable": {"thread_id": "fresh-head-snapshot"}}
-
-    graph.update_state(
-        config,
-        {"messages": [HumanMessage(content="hello", id="m1")]},
-        as_node="model",
-    )
-
-    head = saver.get_tuple(config)
-    assert head is not None
-    assert isinstance(head.checkpoint["channel_values"].get("messages"), _DeltaSnapshot)
-    assert head.metadata is not None
-    assert "counters_since_delta_snapshot" not in head.metadata
-
-
 # ---------------------------------------------------------------------------
 # Non-fresh thread: update_state after invoke
 # ---------------------------------------------------------------------------
 
 
 def test_update_state_after_invoke_delta_channel() -> None:
+    """The non-fresh-thread path was already working before the fix; pin it
+    down so the lazy-stub change for fresh threads doesn't regress it."""
     saver = InMemorySaver()
     graph = _build_graph(saver)
     config = {"configurable": {"thread_id": "after-invoke-sync"}}
@@ -134,12 +110,6 @@ def test_update_state_after_invoke_delta_channel() -> None:
     assert [m.content for m in state.values["messages"]] == ["seed", "appended"]
     assert [m.id for m in state.values["messages"]] == ["m1", "m2"]
 
-    head = saver.get_tuple(config)
-    assert head is not None
-    assert "messages" not in head.checkpoint["channel_values"]
-    assert head.metadata is not None
-    assert head.metadata["counters_since_delta_snapshot"]["messages"] == [2, 4]
-
 
 async def test_aupdate_state_after_invoke_delta_channel() -> None:
     saver = InMemorySaver()
@@ -163,6 +133,9 @@ async def test_aupdate_state_after_invoke_delta_channel() -> None:
 
 
 def test_consecutive_update_states_delta_channel() -> None:
+    """First update_state lazily persists a stub; the second sees a real
+    parent (`saved is not None`) and takes the original write path. Both
+    messages must round-trip in chronological order."""
     saver = InMemorySaver()
     graph = _build_graph(saver)
     config = {"configurable": {"thread_id": "consecutive-sync"}}
@@ -182,39 +155,6 @@ def test_consecutive_update_states_delta_channel() -> None:
     assert [m.content for m in state.values["messages"]] == ["first", "second"]
     assert [m.id for m in state.values["messages"]] == ["m1", "m2"]
 
-    head = saver.get_tuple(config)
-    assert head is not None
-    assert "messages" not in head.checkpoint["channel_values"]
-    assert head.metadata is not None
-    assert head.metadata["counters_since_delta_snapshot"]["messages"] == [1, 1]
-
-
-def test_update_state_snapshots_at_frequency() -> None:
-    """Non-fresh update_state snapshots when counters reach snapshot_frequency."""
-    saver = InMemorySaver()
-    graph = _build_graph(saver, snapshot_frequency=1)
-    config = {"configurable": {"thread_id": "snapshot-at-freq"}}
-
-    graph.update_state(
-        config,
-        {"messages": [HumanMessage(content="first", id="m1")]},
-        as_node="model",
-    )
-    graph.update_state(
-        config,
-        {"messages": [HumanMessage(content="second", id="m2")]},
-        as_node="model",
-    )
-
-    state = graph.get_state(config)
-    assert [m.content for m in state.values["messages"]] == ["first", "second"]
-
-    head = saver.get_tuple(config)
-    assert head is not None
-    assert isinstance(head.checkpoint["channel_values"].get("messages"), _DeltaSnapshot)
-    assert head.metadata is not None
-    assert "counters_since_delta_snapshot" not in head.metadata
-
 
 async def test_aconsecutive_update_states_delta_channel() -> None:
     saver = InMemorySaver()
@@ -278,6 +218,7 @@ def test_bulk_update_state_multi_task_per_superstep_delta_channel() -> None:
     different `StateUpdate`s targeting the same node — otherwise both share
     the deterministic interrupt-derived id and collide in the saver.
     """
+    from langgraph.types import StateUpdate
 
     saver = InMemorySaver()
     graph = _build_graph(saver)
@@ -311,14 +252,14 @@ def test_bulk_update_state_multi_task_per_superstep_delta_channel() -> None:
 
 
 # ---------------------------------------------------------------------------
-# Public-API observation of fresh-thread checkpoint shape
+# Public-API observation of the lazy-stub mechanism
 # ---------------------------------------------------------------------------
 
 
 def test_state_history_chain_after_fresh_update_state_delta_channel() -> None:
-    """A fresh-thread `update_state` should produce a single self-contained
-    checkpoint visible via `get_state_history`: step=0, `source='update'`,
-    no parent, with the DeltaChannel value snapshotted inline."""
+    """A fresh-thread `update_state` should produce two checkpoints visible
+    via `get_state_history`: a stub (step=-1, no parent) and the update
+    (step=0, parent=stub). Both attributed `source='update'`."""
     saver = InMemorySaver()
     graph = _build_graph(saver)
     config = {"configurable": {"thread_id": "history-chain"}}
@@ -329,12 +270,25 @@ def test_state_history_chain_after_fresh_update_state_delta_channel() -> None:
         as_node="model",
     )
 
+    # Newest first per `get_state_history` ordering.
     history = list(graph.get_state_history(config))
-    assert len(history) == 1
+    assert len(history) == 2
+
+    update_snapshot, stub_snapshot = history
 
-    (update_snapshot,) = history
     assert update_snapshot.metadata is not None
     assert update_snapshot.metadata["source"] == "update"
     assert update_snapshot.metadata["step"] == 0
-    assert update_snapshot.parent_config is None
     assert [m.content for m in update_snapshot.values["messages"]] == ["hello"]
+
+    assert stub_snapshot.metadata is not None
+    assert stub_snapshot.metadata["source"] == "update"
+    assert stub_snapshot.metadata["step"] == -1
+    assert stub_snapshot.parent_config is None
+
+    # The update checkpoint's parent is the stub.
+    assert update_snapshot.parent_config is not None
+    assert (
+        update_snapshot.parent_config["configurable"]["checkpoint_id"]
+        == stub_snapshot.config["configurable"]["checkpoint_id"]
+    )

libs/langgraph/tests/test_deprecation.py

@@ -88,13 +88,13 @@ def test_constants_deprecation() -> None:
         LangGraphDeprecatedSinceV10,
         match="Importing Send from langgraph.constants is deprecated. Please use 'from langgraph.types import Send' instead.",
     ):
-        from langgraph.constants import Send  # noqa: PLC0415, F401
+        from langgraph.constants import Send  # noqa: F401
 
     with pytest.warns(
         LangGraphDeprecatedSinceV10,
         match="Importing Interrupt from langgraph.constants is deprecated. Please use 'from langgraph.types import Interrupt' instead.",
     ):
-        from langgraph.constants import Interrupt  # noqa: PLC0415, F401
+        from langgraph.constants import Interrupt  # noqa: F401
 
 
 def test_pregel_types_deprecation() -> None:
@@ -102,7 +102,7 @@ def test_pregel_types_deprecation() -> None:
         LangGraphDeprecatedSinceV10,
         match="Importing from langgraph.pregel.types is deprecated. Please use 'from langgraph.types import ...' instead.",
     ):
-        from langgraph.pregel.types import StateSnapshot  # noqa: PLC0415, F401
+        from langgraph.pregel.types import StateSnapshot  # noqa: F401
 
 
 def test_config_schema_deprecation() -> None:
@@ -195,7 +195,7 @@ def test_deprecated_import() -> None:
         LangGraphDeprecatedSinceV10,
         match="Importing PREVIOUS from langgraph.constants is deprecated. This constant is now private and should not be used directly.",
     ):
-        from langgraph.constants import PREVIOUS  # noqa: PLC0415, F401
+        from langgraph.constants import PREVIOUS  # noqa: F401
 
 
 @pytest.mark.filterwarnings(

libs/langgraph/tests/test_graph_callbacks.py

@@ -13,7 +13,6 @@ from langgraph.callbacks import (
     GraphCallbackHandler,
     GraphInterruptEvent,
     GraphResumeEvent,
-    _GraphCallbackManager,
 )
 from langgraph.graph import START, StateGraph
 from langgraph.types import Command, Interrupt, interrupt
@@ -287,6 +286,7 @@ def test_non_graph_handler_via_add_handler_does_not_crash() -> None:
     GraphCallbackHandler. They must be silently accepted — graph lifecycle
     events will simply not be dispatched to them.
     """
+    from langgraph.callbacks import _GraphCallbackManager
 
     manager = _GraphCallbackManager()
     plain_handler = _LangChainCustomEventHandler()

libs/langgraph/tests/test_large_cases.py

@@ -2,26 +2,11 @@ import json
 import operator
 import re
 import time
-from copy import deepcopy
 from dataclasses import replace
 from typing import Annotated, Any, Literal, cast
 
 import pytest
-from langchain_core.callbacks import CallbackManagerForLLMRun
-from langchain_core.language_models.fake import FakeStreamingListLLM
-from langchain_core.language_models.fake_chat_models import (
-    FakeMessagesListChatModel,
-)
-from langchain_core.messages import (
-    AIMessage,
-    AnyMessage,
-    BaseMessage,
-    HumanMessage,
-    ToolCall,
-    ToolMessage,
-)
-from langchain_core.outputs import ChatGeneration, ChatResult
-from langchain_core.prompts import PromptTemplate
+from langchain_core.messages import AIMessage, AnyMessage, ToolCall
 from langchain_core.runnables import RunnableConfig, RunnableMap, RunnablePick
 from langchain_core.tools import tool
 from langchain_core.version import VERSION as LANGCHAIN_CORE_VERSION
@@ -499,6 +484,9 @@ def test_conditional_state_graph(
     snapshot: SnapshotAssertion,
     sync_checkpointer: BaseCheckpointSaver,
 ) -> None:
+    from langchain_core.language_models.fake import FakeStreamingListLLM
+    from langchain_core.prompts import PromptTemplate
+    from langchain_core.tools import tool
 
     class AgentState(TypedDict, total=False):
         input: Annotated[str, UntrackedValue]
@@ -1273,6 +1261,8 @@ def test_conditional_state_graph(
 
 
 def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None:
+    from langchain_core.messages import AIMessage, HumanMessage
+    from langchain_core.tools import tool
 
     @tool()
     def search_api(query: str) -> str:
@@ -1636,6 +1626,17 @@ def test_prebuilt_tool_chat(snapshot: SnapshotAssertion) -> None:
 def test_state_graph_packets(
     sync_checkpointer: BaseCheckpointSaver, mocker: MockerFixture
 ) -> None:
+    from langchain_core.language_models.fake_chat_models import (
+        FakeMessagesListChatModel,
+    )
+    from langchain_core.messages import (
+        AIMessage,
+        BaseMessage,
+        HumanMessage,
+        ToolCall,
+        ToolMessage,
+    )
+    from langchain_core.tools import tool
 
     class AgentState(TypedDict):
         messages: Annotated[list[BaseMessage], add_messages]
@@ -2380,6 +2381,15 @@ def test_message_graph(
     deterministic_uuids: MockerFixture,
     sync_checkpointer: BaseCheckpointSaver,
 ) -> None:
+    from copy import deepcopy
+
+    from langchain_core.callbacks import CallbackManagerForLLMRun
+    from langchain_core.language_models.fake_chat_models import (
+        FakeMessagesListChatModel,
+    )
+    from langchain_core.messages import AIMessage, BaseMessage, HumanMessage
+    from langchain_core.outputs import ChatGeneration, ChatResult
+    from langchain_core.tools import tool
 
     class FakeFunctionChatModel(FakeMessagesListChatModel):
         def bind_functions(self, functions: list):
@@ -3089,6 +3099,20 @@ def test_root_graph(
     deterministic_uuids: MockerFixture,
     sync_checkpointer: BaseCheckpointSaver,
 ) -> None:
+    from copy import deepcopy
+
+    from langchain_core.callbacks import CallbackManagerForLLMRun
+    from langchain_core.language_models.fake_chat_models import (
+        FakeMessagesListChatModel,
+    )
+    from langchain_core.messages import (
+        AIMessage,
+        BaseMessage,
+        HumanMessage,
+        ToolMessage,
+    )
+    from langchain_core.outputs import ChatGeneration, ChatResult
+    from langchain_core.tools import tool
 
     class FakeFunctionChatModel(FakeMessagesListChatModel):
         def bind_functions(self, functions: list):
@@ -5813,6 +5837,7 @@ def test_send_to_nested_graphs(sync_checkpointer: BaseCheckpointSaver) -> None:
 def test_send_react_interrupt(
     sync_checkpointer: BaseCheckpointSaver,
 ) -> None:
+    from langchain_core.messages import AIMessage, HumanMessage, ToolCall, ToolMessage
 
     ai_message = AIMessage(
         "",
@@ -6203,6 +6228,7 @@ def test_send_react_interrupt(
 def test_send_react_interrupt_control(
     sync_checkpointer: BaseCheckpointSaver, snapshot: SnapshotAssertion
 ) -> None:
+    from langchain_core.messages import AIMessage, HumanMessage, ToolCall, ToolMessage
 
     ai_message = AIMessage(
         "",
@@ -6429,6 +6455,9 @@ def test_send_react_interrupt_control(
 def test_weather_subgraph(
     sync_checkpointer: BaseCheckpointSaver, snapshot: SnapshotAssertion
 ) -> None:
+    from langchain_core.language_models.fake_chat_models import (
+        FakeMessagesListChatModel,
+    )
 
     # setup subgraph
 

libs/langgraph/tests/test_large_cases_async.py

@@ -9,22 +9,8 @@ from typing import (
 )
 
 import pytest
-from langchain_core.agents import AgentAction, AgentFinish
-from langchain_core.language_models.fake import FakeStreamingListLLM
-from langchain_core.language_models.fake_chat_models import (
-    FakeMessagesListChatModel,
-)
-from langchain_core.messages import (
-    AIMessage,
-    AnyMessage,
-    BaseMessage,
-    HumanMessage,
-    ToolCall,
-    ToolMessage,
-)
-from langchain_core.prompts import PromptTemplate
+from langchain_core.messages import AnyMessage, ToolCall
 from langchain_core.runnables import RunnableConfig, RunnablePick
-from langchain_core.tools import tool
 from langchain_core.version import VERSION as LANGCHAIN_CORE_VERSION
 from langgraph.checkpoint.base import BaseCheckpointSaver
 from langgraph.prebuilt.chat_agent_executor import create_react_agent
@@ -36,7 +22,6 @@ from langgraph._internal._constants import PULL, PUSH
 from langgraph.channels.last_value import LastValue
 from langgraph.channels.untracked_value import UntrackedValue
 from langgraph.constants import END, START
-from langgraph.graph import MessagesState
 from langgraph.graph.message import add_messages
 from langgraph.graph.state import StateGraph
 from langgraph.pregel import NodeBuilder, Pregel
@@ -494,6 +479,10 @@ async def test_fork_always_re_runs_nodes(
 
 
 async def test_conditional_graph_state(async_checkpointer: BaseCheckpointSaver) -> None:
+    from langchain_core.agents import AgentAction, AgentFinish
+    from langchain_core.language_models.fake import FakeStreamingListLLM
+    from langchain_core.prompts import PromptTemplate
+    from langchain_core.tools import tool
 
     class AgentState(TypedDict):
         input: Annotated[str, UntrackedValue]
@@ -1028,6 +1017,8 @@ async def test_conditional_graph_state(async_checkpointer: BaseCheckpointSaver)
 
 
 async def test_prebuilt_tool_chat() -> None:
+    from langchain_core.messages import AIMessage, HumanMessage
+    from langchain_core.tools import tool
 
     model = FakeChatModel(
         messages=[
@@ -1367,6 +1358,16 @@ async def test_prebuilt_tool_chat() -> None:
 
 
 async def test_state_graph_packets(async_checkpointer: BaseCheckpointSaver) -> None:
+    from langchain_core.language_models.fake_chat_models import (
+        FakeMessagesListChatModel,
+    )
+    from langchain_core.messages import (
+        AIMessage,
+        BaseMessage,
+        HumanMessage,
+        ToolMessage,
+    )
+    from langchain_core.tools import tool
 
     class AgentState(TypedDict):
         messages: Annotated[list[BaseMessage], add_messages]
@@ -2071,6 +2072,11 @@ async def test_state_graph_packets(async_checkpointer: BaseCheckpointSaver) -> N
 
 
 async def test_message_graph(async_checkpointer: BaseCheckpointSaver) -> None:
+    from langchain_core.language_models.fake_chat_models import (
+        FakeMessagesListChatModel,
+    )
+    from langchain_core.messages import AIMessage, HumanMessage
+    from langchain_core.tools import tool
 
     class FakeFunctionChatModel(FakeMessagesListChatModel):
         def bind_functions(self, functions: list):
@@ -3531,6 +3537,13 @@ async def test_send_to_nested_graphs(async_checkpointer: BaseCheckpointSaver) ->
 async def test_weather_subgraph(
     async_checkpointer: BaseCheckpointSaver,
 ) -> None:
+    from langchain_core.language_models.fake_chat_models import (
+        FakeMessagesListChatModel,
+    )
+    from langchain_core.messages import AIMessage, ToolCall
+    from langchain_core.tools import tool
+
+    from langgraph.graph import MessagesState
 
     # setup subgraph