refactor(cli): simplify tenant ID helper

refactor(cli): extract tenant ID resolution
refactor(cli): resolve workspace alias into tenant_id
2026-09-26 19:45:00 +02:00 · 2026-09-13 14:14:43 -07:00 · 2026-09-13 14:11:07 -07:00 · 2026-09-13 14:08:58 -07:00 · 2026-09-13 14:04:49 -07:00 · 2026-09-13 14:02:55 -07:00
40 changed files with 1082 additions and 2984 deletions
@@ -7,10 +7,6 @@ on:
    paths:
      - 'docs/**'
      - '.github/workflows/deploy-redirects.yml'
  # llms.txt is fetched from docs.langchain.com at build time, so redeploy on a
  # schedule to pick up docs changes that never touch this repo.
  schedule:
    - cron: '17 6 * * 1'
  workflow_dispatch:
 permissions:
@@ -0,0 +1,65 @@
 # AGENTS Instructions
 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
 - `make lint` – run the linter
 - `make test` – execute the test suite
 To run a particular test file or to pass additional pytest options you can specify the `TEST` variable:
 ```
 TEST=path/to/test.py make test
 ```
 Other pytest arguments can also be supplied inside the `TEST` variable.
 ## Libraries
 The repository contains several Python and JavaScript/TypeScript libraries.
 Below is a high-level overview:
 - **checkpoint** – base interfaces for LangGraph checkpointers.
 - **checkpoint-postgres** – Postgres implementation of the checkpoint saver.
 - **checkpoint-sqlite** – SQLite implementation of the checkpoint saver.
 - **cli** – official command-line interface for LangGraph.
 - **langgraph** – core framework for building stateful, multi-actor agents.
 - **prebuilt** – high-level APIs for creating and running agents and tools.
 - **sdk-js** – JS/TS SDK for interacting with the LangGraph REST API.
 - **sdk-py** – Python SDK for the LangGraph Server API.
 ### Dependency map
 The diagram below lists downstream libraries for each production dependency as
 declared in that library's `pyproject.toml` (or `package.json`).
 ```text
 checkpoint
 ├── checkpoint-postgres
 ├── checkpoint-sqlite
 ├── prebuilt
 └── langgraph
 prebuilt
 └── langgraph
 sdk-py
 ├── langgraph
 └── cli
 sdk-js (standalone)
 ```
 Changes to a library may impact all of its dependents shown above.
 - Do NOT use Sphinx-style double backtick formatting (` ``code`` `). Use single backticks (`` `code` ``) for inline code references in docstrings and comments.
@@ -12,26 +12,13 @@ which is SEO-friendly and treated similarly to 301 redirects by Google.
 To add new redirects, simply edit redirects.json and re-run this script.
 """
 import http.client
 import json
 import os
 import urllib.error
 import urllib.parse
 import urllib.request
 from pathlib import Path
 # Default fallback URL for any path not in the redirect map
 DEFAULT_REDIRECT = "https://docs.langchain.com/oss/python/langgraph/overview"
 # The docs site regenerates this index on every deploy, so fetching it here
 # keeps the published llms.txt from drifting. The URL is a hardcoded constant,
 # never built from input, and both it and the post-redirect URL are checked
 # against ALLOWED_LLMS_HOST before anything is read.
 CANONICAL_LLMS_URL = "https://docs.langchain.com/oss/python/langgraph/llms.txt"
 ALLOWED_LLMS_HOST = "docs.langchain.com"
 LLMS_FETCH_TIMEOUT = 30
 LLMS_MAX_BYTES = 1_000_000
 HTML_TEMPLATE = """<!doctype html>
 <html lang="en">
 <head>
@@ -88,64 +75,6 @@ CATCHALL_404_TEMPLATE = """<!doctype html>
 """
 def is_allowed_llms_url(url):
    """Return True if url is HTTPS on the one host we accept content from."""
    parsed = urllib.parse.urlsplit(url)
    return parsed.scheme == "https" and parsed.hostname == ALLOWED_LLMS_HOST
 def fetch_canonical_llms_txt():
    """Return the published LangGraph index, or None if it cannot be used.
    Returning None leaves the caller on the committed docs/llms.txt, so a
    docs.langchain.com outage degrades to a stale file rather than a broken
    deploy or a published error page.
    """
    if not is_allowed_llms_url(CANONICAL_LLMS_URL):
        print(f"Refusing to fetch {CANONICAL_LLMS_URL}: host not allowed")
        return None
    try:
        with urllib.request.urlopen(  # noqa: S310 - constant, allowlisted URL
            CANONICAL_LLMS_URL, timeout=LLMS_FETCH_TIMEOUT
        ) as response:
            # urlopen follows redirects, so re-check where it actually landed.
            if not is_allowed_llms_url(response.url):
                print(f"Refusing {CANONICAL_LLMS_URL}: redirected to {response.url}")
                return None
            body = response.read(LLMS_MAX_BYTES + 1)
    # A connection dropped mid-body raises http.client.IncompleteRead, which
    # descends from HTTPException rather than OSError, so catching only the
    # urllib and OS errors would let it escape and fail the whole deploy.
    except (
        urllib.error.URLError,
        http.client.HTTPException,
        TimeoutError,
        OSError,
    ) as exc:
        print(f"Could not fetch {CANONICAL_LLMS_URL}: {type(exc).__name__}: {exc}")
        return None
    if len(body) > LLMS_MAX_BYTES:
        print(f"Refusing {CANONICAL_LLMS_URL}: larger than {LLMS_MAX_BYTES} bytes")
        return None
    try:
        text = body.decode("utf-8")
    except UnicodeDecodeError as exc:
        print(f"Refusing {CANONICAL_LLMS_URL}: not valid UTF-8: {exc}")
        return None
    # An index opens with a markdown heading and links to the docs site. A
    # body that does not is an error page or a truncated response, not content
    # worth publishing.
    if not text.startswith("# ") or f"https://{ALLOWED_LLMS_HOST}/" not in text:
        print(f"Refusing {CANONICAL_LLMS_URL}: does not look like an llms.txt index")
        return None
    return text
 def generate_redirects():
    script_dir = Path(__file__).parent
    output_dir = script_dir / "_site"
@@ -197,19 +126,14 @@ def generate_redirects():
    catchall_404.write_text(CATCHALL_404_TEMPLATE.format(default_url=DEFAULT_REDIRECT))
    print(f"Created: {catchall_404}")
-    # llms.txt can't be redirected via HTML, so publish the docs site's own
+    # Copy static files (like llms.txt) that can't be redirected via HTML
-    # generated index. The committed copy is only a fallback.
+    static_files = ["llms.txt"]
-    llms_txt = fetch_canonical_llms_txt()
+    for static_file in static_files:
-    if llms_txt is not None:
+        src = script_dir / static_file
        (output_dir / "llms.txt").write_text(llms_txt)
        print(f"Fetched: {output_dir / 'llms.txt'} (from {CANONICAL_LLMS_URL})")
    else:
        src = script_dir / "llms.txt"
        if src.exists():
-            (output_dir / "llms.txt").write_text(src.read_text())
+            dst = output_dir / static_file
-            print(f"Copied: {output_dir / 'llms.txt'} (fallback, may be stale)")
+            dst.write_text(src.read_text())
-        else:
+            print(f"Copied: {dst}")
            print("No llms.txt fetched and no committed fallback; skipping")
    print(f"\nGenerated {len(redirects)} redirect files in {output_dir}")
@@ -1,49 +1,35 @@
-# Docs by LangChain: LangGraph (Python)
+# LangGraph
-> Markdown index of the LangGraph (Python) documentation.
+LangGraph documentation has moved to docs.langchain.com.
-## LangGraph (Python)
+## Overview
- [Memory](https://docs.langchain.com/oss/python/langgraph/add-memory.md)
+- [LangGraph Overview](https://docs.langchain.com/oss/python/langgraph/overview): Introduction to LangGraph, a library for building stateful, multi-actor applications with LLMs.
- [Build a custom RAG agent with LangGraph](https://docs.langchain.com/oss/python/langgraph/agentic-rag.md)
+- [Why LangGraph?](https://docs.langchain.com/oss/python/langgraph/why-langgraph): Motivation for LangGraph and its key features.
- [Application structure](https://docs.langchain.com/oss/python/langgraph/application-structure.md)
+
- [Backward compatibility](https://docs.langchain.com/oss/python/langgraph/backward-compatibility.md)
+## Core Concepts
- [Case studies](https://docs.langchain.com/oss/python/langgraph/case-studies.md)
+
- [Changelog](https://docs.langchain.com/oss/python/langgraph/changelog-js.md)
+- [Graph API](https://docs.langchain.com/oss/python/langgraph/graph-api): Learn how to define state, create nodes, and connect them with edges.
- [Changelog](https://docs.langchain.com/oss/python/langgraph/changelog-py.md)
+- [Streaming](https://docs.langchain.com/oss/python/langgraph/streaming): Stream outputs from your graph for better UX.
- [Checkpointers](https://docs.langchain.com/oss/python/langgraph/checkpointers.md)
+- [Persistence](https://docs.langchain.com/oss/python/langgraph/persistence): Add memory and checkpointing to your graphs.
- [Choosing between Graph and Functional APIs](https://docs.langchain.com/oss/python/langgraph/choosing-apis.md)
+- [Add Memory](https://docs.langchain.com/oss/python/langgraph/add-memory): Implement short-term and long-term memory.
- [Deployment](https://docs.langchain.com/oss/python/langgraph/deploy.md)
+- [Workflows & Agents](https://docs.langchain.com/oss/python/langgraph/workflows-agents): Build agents and workflows with LangGraph.
- [GRAPH_RECURSION_LIMIT](https://docs.langchain.com/oss/python/langgraph/errors/GRAPH_RECURSION_LIMIT.md)
+
- [INVALID_CHAT_HISTORY](https://docs.langchain.com/oss/python/langgraph/errors/INVALID_CHAT_HISTORY.md)
+## How-To Guides
- [INVALID_CONCURRENT_GRAPH_UPDATE](https://docs.langchain.com/oss/python/langgraph/errors/INVALID_CONCURRENT_GRAPH_UPDATE.md)
+
- [INVALID_GRAPH_NODE_RETURN_VALUE](https://docs.langchain.com/oss/python/langgraph/errors/INVALID_GRAPH_NODE_RETURN_VALUE.md)
+- [Use Subgraphs](https://docs.langchain.com/oss/python/langgraph/use-subgraphs): Compose graphs using subgraphs.
- [MISSING_CHECKPOINTER](https://docs.langchain.com/oss/python/langgraph/errors/MISSING_CHECKPOINTER.md)
+- [Observability](https://docs.langchain.com/oss/python/langgraph/observability): Add tracing and debugging to your graphs.
- [MULTIPLE_SUBGRAPHS](https://docs.langchain.com/oss/python/langgraph/errors/MULTIPLE_SUBGRAPHS.md)
+- [Common Errors](https://docs.langchain.com/oss/python/langgraph/common-errors): Troubleshoot common LangGraph errors.
- [Event streaming](https://docs.langchain.com/oss/python/langgraph/event-streaming.md)
+
- [Fault tolerance](https://docs.langchain.com/oss/python/langgraph/fault-tolerance.md)
+## Tutorials
- [Custom stream channels](https://docs.langchain.com/oss/python/langgraph/frontend/custom-stream-channels.md)
+
- [Graph execution](https://docs.langchain.com/oss/python/langgraph/frontend/graph-execution.md)
+- [Agentic RAG](https://docs.langchain.com/oss/python/langgraph/agentic-rag): Build an agentic RAG system with LangGraph.
- [Overview](https://docs.langchain.com/oss/python/langgraph/frontend/overview.md)
+- [SQL Agent](https://docs.langchain.com/oss/python/langgraph/sql-agent): Create a SQL agent with LangGraph.
- [Functional API overview](https://docs.langchain.com/oss/python/langgraph/functional-api.md)
+
- [Graph API overview](https://docs.langchain.com/oss/python/langgraph/graph-api.md)
+## Reference
- [Install LangGraph](https://docs.langchain.com/oss/python/langgraph/install.md)
+
- [Interrupts](https://docs.langchain.com/oss/python/langgraph/interrupts.md)
+- [API Reference](https://reference.langchain.com/python/langgraph/): Complete API documentation for LangGraph.
- [Run a local server](https://docs.langchain.com/oss/python/langgraph/local-server.md)
+
- [LangSmith Observability](https://docs.langchain.com/oss/python/langgraph/observability.md)
+## LangGraph Platform
- [LangGraph overview](https://docs.langchain.com/oss/python/langgraph/overview.md)
+
- [Persistence](https://docs.langchain.com/oss/python/langgraph/persistence.md)
+For deploying LangGraph applications in production, see the [LangSmith documentation](https://docs.langchain.com/langsmith/agent-server).
 - [LangGraph runtime](https://docs.langchain.com/oss/python/langgraph/pregel.md)
 - [Quickstart](https://docs.langchain.com/oss/python/langgraph/quickstart.md)
 - [Build a custom SQL agent](https://docs.langchain.com/oss/python/langgraph/sql-agent.md)
 - [Stores](https://docs.langchain.com/oss/python/langgraph/stores.md)
 - [Streaming](https://docs.langchain.com/oss/python/langgraph/streaming.md)
 - [LangSmith Studio](https://docs.langchain.com/oss/python/langgraph/studio.md)
 - [Test](https://docs.langchain.com/oss/python/langgraph/test.md)
 - [Thinking in LangGraph](https://docs.langchain.com/oss/python/langgraph/thinking-in-langgraph.md)
 - [Agent Chat UI](https://docs.langchain.com/oss/python/langgraph/ui.md)
 - [Use the functional API](https://docs.langchain.com/oss/python/langgraph/use-functional-api.md)
 - [Use the graph API](https://docs.langchain.com/oss/python/langgraph/use-graph-api.md)
 - [Subgraphs](https://docs.langchain.com/oss/python/langgraph/use-subgraphs.md)
 - [Use time-travel](https://docs.langchain.com/oss/python/langgraph/use-time-travel.md)
 - [Workflows and agents](https://docs.langchain.com/oss/python/langgraph/workflows-agents.md)
@@ -267,61 +267,6 @@ async def test_history_seed_ancestor_own_writes_are_replayed(
    )
 # Every uuid4 `build_delta_chain` tags its own writes with sorts between these
 # two, so task_id order is fixed and always disagrees with task_path order.
 TASK_ID_SORTS_FIRST = "00000000-0000-0000-0000-000000000000"
 TASK_ID_SORTS_LAST = "zzzzzzzz-0000-0000-0000-000000000000"
 async def test_history_orders_parallel_writes_by_task_path(
    saver: BaseCheckpointSaver,
 ) -> None:
    """Writes from parallel tasks replay in task_path order, not task_id order."""
    configs = await build_delta_chain(
        saver,
        thread_id=str(uuid4()),
        channel="ch",
        snapshots_at_steps=[0],
        total_steps=3,
    )
    step_1, head = configs[1], configs[2]
    await saver.aput_writes(
        step_1, [("ch", "second")], TASK_ID_SORTS_FIRST, "~pull, 02"
    )
    await saver.aput_writes(step_1, [("ch", "first")], TASK_ID_SORTS_LAST, "~pull, 01")
    result = await saver.aget_delta_channel_history(config=head, channels=["ch"])
    values = [w[2] for w in result["ch"]["writes"]]
    assert values == [1, "first", "second"], (
        f"Expected task_path order [1, 'first', 'second'], got {values}. "
        "Ordering by (task_id, idx) alone yields [1, 'second', 'first']."
    )
 async def test_history_orders_pathless_writes_first(
    saver: BaseCheckpointSaver,
 ) -> None:
    """Writes stored without a task_path (graph input) replay before task writes."""
    configs = await build_delta_chain(
        saver,
        thread_id=str(uuid4()),
        channel="ch",
        snapshots_at_steps=[0],
        total_steps=3,
    )
    step_1, head = configs[1], configs[2]
    await saver.aput_writes(
        step_1, [("ch", "from_node")], TASK_ID_SORTS_FIRST, "~pull, a"
    )
    await saver.aput_writes(step_1, [("ch", "from_input")], TASK_ID_SORTS_LAST)
    result = await saver.aget_delta_channel_history(config=head, channels=["ch"])
    values = [w[2] for w in result["ch"]["writes"]]
    assert values == [1, "from_input", "from_node"], (
        f"Expected pathless writes first, got {values}"
    )
 ALL_DELTA_CHANNEL_HISTORY_TESTS = [
    test_history_returns_writes_oldest_first,
    test_history_seed_is_nearest_snapshot,
@@ -331,8 +276,6 @@ ALL_DELTA_CHANNEL_HISTORY_TESTS = [
    test_history_walk_to_root_no_seed,
    test_history_migration_plain_value_as_seed,
    test_history_seed_ancestor_own_writes_are_replayed,
    test_history_orders_parallel_writes_by_task_path,
    test_history_orders_pathless_writes_first,
 ]
@@ -13,16 +13,16 @@ wheels = [
 [[package]]
 name = "anyio"
-version = "4.14.2"
+version = "4.13.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "exceptiongroup", marker = "python_full_version < '3.11'" },
    { name = "idna" },
    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/61/cc/a381afa6efea9f496eff839d4a6a1aed3bfafc7b3ab4b0d1b243a12573dd/anyio-4.14.2.tar.gz", hash = "sha256:cfa139f3ed1a23ee8f88a145ddb5ac7605b8bbfd8592baacd7ce3d8bb4313c7f", size = 260176, upload-time = "2026-07-12T20:29:07.082Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/19/14/2c5dd9f512b66549ae92767a9c7b330ae88e1932ca57876909410251fe13/anyio-4.13.0.tar.gz", hash = "sha256:334b70e641fd2221c1505b3890c69882fe4a2df910cba14d97019b90b24439dc", size = 231622, upload-time = "2026-03-24T12:59:09.671Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/da/35/f2287558c17e29fafc8ef3daf819bb9834061cfa43bff8014f7df7f63bdc/anyio-4.14.2-py3-none-any.whl", hash = "sha256:9f505dda5ac9f0c8309b5e8bd445a8c2bf7246f3ce950121e45ea15bc41d1494", size = 125813, upload-time = "2026-07-12T20:29:05.763Z" },
+    { url = "https://files.pythonhosted.org/packages/da/42/e921fccf5015463e32a3cf6ee7f980a6ed0f395ceeaa45060b61d86486c2/anyio-4.13.0-py3-none-any.whl", hash = "sha256:08b310f9e24a9594186fd75b4f73f4a4152069e3853f1ed8bfbf58369f4ad708", size = 114353, upload-time = "2026-03-24T12:59:08.246Z" },
 ]
 [[package]]
@@ -168,7 +168,6 @@ class _DeltaStage2Row(TypedDict, total=False):
    type: str | None
    blob: bytes | None
    task_id: str | None  # "w" rows only
    task_path: str | None  # "w" rows only
    idx: int | None  # "w" rows only
    version: str | None  # "b" rows only
@@ -320,7 +319,7 @@ def _build_delta_stage2_sql(
        branches.append(
            "SELECT 'w'::text AS _kind, "
            "checkpoint_id, channel, "
-            "type, blob, task_id, task_path, idx, NULL::text AS version "
+            "type, blob, task_id, idx, NULL::text AS version "
            "FROM checkpoint_writes "
            "WHERE thread_id = %s AND checkpoint_ns = %s AND channel = %s "
            "AND checkpoint_id = ANY(%s)"
@@ -328,8 +327,7 @@ def _build_delta_stage2_sql(
    for _ in channels_with_seed:
        branches.append(
            "SELECT 'b'::text AS _kind, NULL::text AS checkpoint_id, channel, "
-            "type, blob, NULL::text AS task_id, NULL::text AS task_path, "
+            "type, blob, NULL::text AS task_id, NULL::int AS idx, version "
            "NULL::int AS idx, version "
            "FROM checkpoint_blobs "
            "WHERE thread_id = %s AND checkpoint_ns = %s AND channel = %s "
            "AND version = %s"
@@ -494,11 +492,10 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
        stored value, 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
+        # writes_by_ch_by_cid[channel][cid] = list of (type, blob, task_id, idx)
-        # (type, blob, task_id, idx, task_path)
+        writes_by_ch_by_cid: dict[str, dict[str, list[tuple[str, bytes, str, int]]]] = {
-        writes_by_ch_by_cid: dict[
+            ch: {} for ch in channels
-            str, dict[str, list[tuple[str, bytes, str, int, str]]]
+        }
        ] = {ch: {} for ch in channels}
        # seed_blob_by_ver[(channel, version)] = (type, blob)
        seed_blob_by_ver: dict[tuple[str, str], tuple[str, bytes]] = {}
@@ -509,14 +506,8 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
                cid = cast(str, r["checkpoint_id"])
                writes_by_ch_by_cid.setdefault(ch, {}).setdefault(cid, []).append(
                    cast(
-                        "tuple[str, bytes, str, int, str]",
+                        "tuple[str, bytes, str, int]",
-                        (
+                        (r["type"], r["blob"], r["task_id"], r["idx"]),
                            r["type"],
                            r["blob"],
                            r["task_id"],
                            r["idx"],
                            r["task_path"],
                        ),
                    )
                )
            else:  # kind == "b"
@@ -525,10 +516,10 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
                    "tuple[str, bytes]", (r["type"], r["blob"])
                )
-        # Sort writes per (channel, cid) newest-first by (task_path, task_id, idx)
+        # Sort writes per (channel, cid) newest-first by (task_id, idx)
        for cid_map in writes_by_ch_by_cid.values():
            for ws in cid_map.values():
-                ws.sort(key=lambda w: (w[4], w[2], w[3]), reverse=True)
+                ws.sort(key=lambda w: (w[2], w[3]), reverse=True)
        result: dict[str, DeltaChannelHistory] = {}
        for ch in channels:
@@ -538,9 +529,7 @@ class BasePostgresSaver(BaseCheckpointSaver[str]):
            collected: list[PendingWrite] = []
            cid_writes = writes_by_ch_by_cid.get(ch, {})
            for cid in chain_cids:
-                for type_tag, write_blob, task_id, _idx, _path in cid_writes.get(
+                for type_tag, write_blob, task_id, _idx in cid_writes.get(cid, []):
                    cid, []
                ):
                    val = self.serde.loads_typed((type_tag, write_blob))
                    collected.append((task_id, ch, val))
            collected.reverse()
@@ -154,7 +154,6 @@ class SqliteSaver(BaseCheckpointSaver[str]):
                checkpoint_ns TEXT NOT NULL DEFAULT '',
                checkpoint_id TEXT NOT NULL,
                task_id TEXT NOT NULL,
                task_path TEXT NOT NULL DEFAULT '',
                idx INTEGER NOT NULL,
                channel TEXT NOT NULL,
                type TEXT,
@@ -163,15 +162,6 @@ class SqliteSaver(BaseCheckpointSaver[str]):
            );
            """
        )
        # sqlite has no ADD COLUMN IF NOT EXISTS; this migrates databases
        # created before `task_path` existed and is a no-op on the rest.
        try:
            self.conn.execute(
                "ALTER TABLE writes ADD COLUMN task_path TEXT NOT NULL DEFAULT ''"
            )
        except sqlite3.OperationalError as e:
            if "duplicate column name" not in str(e):
                raise
        self.is_setup = True
@@ -470,9 +460,9 @@ class SqliteSaver(BaseCheckpointSaver[str]):
            task_path: Path of the task creating the writes.
        """
        query = (
-            "INSERT OR REPLACE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, task_path, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)"
+            "INSERT OR REPLACE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?)"
            if all(w[0] in WRITES_IDX_MAP for w in writes)
-            else "INSERT OR IGNORE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, task_path, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)"
+            else "INSERT OR IGNORE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?)"
        )
        with self.cursor() as cur:
            cur.executemany(
@@ -483,7 +473,6 @@ class SqliteSaver(BaseCheckpointSaver[str]):
                        str(config["configurable"]["checkpoint_ns"]),
                        str(config["configurable"]["checkpoint_id"]),
                        task_id,
                        task_path,
                        WRITES_IDX_MAP.get(channel, idx),
                        channel,
                        *self.serde.dumps_typed(value),
@@ -579,7 +568,7 @@ class SqliteSaver(BaseCheckpointSaver[str]):
                    )
                cur.execute(stage2_sql, stage2_params)
                stage2_rows = cast(
-                    "list[tuple[str, str, str, int, str, bytes, str]]", cur.fetchall()
+                    "list[tuple[str, str, str, int, str, bytes]]", cur.fetchall()
                )
            else:
                stage2_rows = []
@@ -57,7 +57,7 @@ def build_delta_stage2_sql(*, chain_lens: Sequence[int]) -> str:
    for n in chain_lens:
        cid_placeholders = ",".join("?" * n)
        branches.append(
-            "SELECT checkpoint_id, channel, task_id, idx, type, value, task_path "
+            "SELECT checkpoint_id, channel, task_id, idx, type, value "
            "FROM writes "
            "WHERE thread_id = ? AND checkpoint_ns = ? AND channel = ? "
            f"AND checkpoint_id IN ({cid_placeholders})"
@@ -130,31 +130,29 @@ def build_delta_channels_writes_history(
    chain_by_ch: Mapping[str, list[str]],
    seed_val_by_ch: Mapping[str, Any],
    seeded: set[str],
-    stage2_rows: Sequence[tuple[str, str, str, int, str, bytes, str]],
+    stage2_rows: Sequence[tuple[str, str, str, int, str, bytes]],
    serde: Any,
 ) -> dict[str, DeltaChannelHistory]:
    """Demux stage-2 rows per channel; produce per-channel histories.
-    Stage-2 rows are
+    Stage-2 rows are `(checkpoint_id, channel, task_id, idx, type, value)`.
-    `(checkpoint_id, channel, task_id, idx, type, value, task_path)`.
+    Final write order is oldest→newest globally and `(task_id, idx)` within
-    Final write order is oldest→newest globally and
+    a checkpoint, matching the contract on `DeltaChannelHistory.writes`.
    `(task_path, task_id, idx)` within a checkpoint, matching the contract
    on `DeltaChannelHistory.writes`.
    `seed` is omitted when the walk reached a true root with no snapshot
    found (channel never entered `seeded`); consumers treat absence as
    "start empty".
    """
-    writes_by_ch_by_cid: dict[
+    writes_by_ch_by_cid: dict[str, dict[str, list[tuple[str, bytes, str, int]]]] = {
-        str, dict[str, list[tuple[str, bytes, str, int, str]]]
+        ch: {} for ch in channels
-    ] = {ch: {} for ch in channels}
+    }
-    for cid, ch, task_id, idx, type_tag, value_blob, task_path in stage2_rows:
+    for cid, ch, task_id, idx, type_tag, value_blob in stage2_rows:
        writes_by_ch_by_cid.setdefault(ch, {}).setdefault(cid, []).append(
-            (type_tag, value_blob, task_id, idx, task_path)
+            (type_tag, value_blob, task_id, idx)
        )
    for cid_map in writes_by_ch_by_cid.values():
        for ws in cid_map.values():
-            ws.sort(key=lambda w: (w[4], w[2], w[3]))
+            ws.sort(key=lambda w: (w[2], w[3]))
    result: dict[str, DeltaChannelHistory] = {}
    for ch in channels:
@@ -163,7 +161,7 @@ def build_delta_channels_writes_history(
        collected: list[PendingWrite] = []
        # Chain is newest-first; iterate oldest-first for the public order.
        for cid in reversed(chain_cids):
-            for type_tag, value_blob, task_id, _idx, _path in cid_writes.get(cid, []):
+            for type_tag, value_blob, task_id, _idx in cid_writes.get(cid, []):
                collected.append(
                    (task_id, ch, serde.loads_typed((type_tag, value_blob)))
                )
@@ -331,7 +331,6 @@ class AsyncSqliteSaver(BaseCheckpointSaver[str]):
                    checkpoint_ns TEXT NOT NULL DEFAULT '',
                    checkpoint_id TEXT NOT NULL,
                    task_id TEXT NOT NULL,
                    task_path TEXT NOT NULL DEFAULT '',
                    idx INTEGER NOT NULL,
                    channel TEXT NOT NULL,
                    type TEXT,
@@ -342,17 +341,6 @@ class AsyncSqliteSaver(BaseCheckpointSaver[str]):
            ):
                await self.conn.commit()
            # sqlite has no ADD COLUMN IF NOT EXISTS; this migrates databases
            # created before `task_path` existed and is a no-op on the rest.
            try:
                await self.conn.execute(
                    "ALTER TABLE writes ADD COLUMN task_path TEXT NOT NULL DEFAULT ''"
                )
                await self.conn.commit()
            except aiosqlite.OperationalError as e:
                if "duplicate column name" not in str(e):
                    raise
            self.is_setup = True
    async def aget_tuple(self, config: RunnableConfig) -> CheckpointTuple | None:
@@ -588,9 +576,9 @@ class AsyncSqliteSaver(BaseCheckpointSaver[str]):
            task_path: Path of the task creating the writes.
        """
        query = (
-            "INSERT OR REPLACE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, task_path, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)"
+            "INSERT OR REPLACE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?)"
            if all(w[0] in WRITES_IDX_MAP for w in writes)
-            else "INSERT OR IGNORE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, task_path, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)"
+            else "INSERT OR IGNORE INTO writes (thread_id, checkpoint_ns, checkpoint_id, task_id, idx, channel, type, value) VALUES (?, ?, ?, ?, ?, ?, ?, ?)"
        )
        await self.setup()
        async with self.lock, self.conn.cursor() as cur:
@@ -602,7 +590,6 @@ class AsyncSqliteSaver(BaseCheckpointSaver[str]):
                        str(config["configurable"]["checkpoint_ns"]),
                        str(config["configurable"]["checkpoint_id"]),
                        task_id,
                        task_path,
                        WRITES_IDX_MAP.get(channel, idx),
                        channel,
                        *self.serde.dumps_typed(value),
@@ -694,7 +681,7 @@ class AsyncSqliteSaver(BaseCheckpointSaver[str]):
                    )
                await cur.execute(stage2_sql, stage2_params)
                stage2_rows = cast(
-                    "list[tuple[str, str, str, int, str, bytes, str]]",
+                    "list[tuple[str, str, str, int, str, bytes]]",
                    await cur.fetchall(),
                )
            else:
@@ -1,87 +0,0 @@
 import sqlite3
 from pathlib import Path
 import aiosqlite
 import pytest
 from langgraph.checkpoint.base import empty_checkpoint
 from langgraph.checkpoint.sqlite import SqliteSaver
 from langgraph.checkpoint.sqlite.aio import AsyncSqliteSaver
 WRITES_BEFORE_TASK_PATH = """
 CREATE TABLE writes (
    thread_id TEXT NOT NULL,
    checkpoint_ns TEXT NOT NULL DEFAULT '',
    checkpoint_id TEXT NOT NULL,
    task_id TEXT NOT NULL,
    idx INTEGER NOT NULL,
    channel TEXT NOT NULL,
    type TEXT,
    value BLOB,
    PRIMARY KEY (thread_id, checkpoint_ns, checkpoint_id, task_id, idx)
 );
 INSERT INTO writes VALUES ('t', '', 'c', 'old-task', 0, 'ch', 'null', X'');
 """
@pytest.fixture
 def legacy_db(tmp_path: Path) -> Path:
    db = tmp_path / "legacy.sqlite"
    with sqlite3.connect(db) as conn:
        conn.executescript(WRITES_BEFORE_TASK_PATH)
    return db
 def test_setup_migrates_legacy_writes_table_repeatably(legacy_db: Path) -> None:
    for _ in range(2):
        with SqliteSaver.from_conn_string(str(legacy_db)) as saver:
            saver.setup()
            rows = saver.conn.execute(
                "SELECT task_id, task_path FROM writes"
            ).fetchall()
            assert rows == [("old-task", "")]
@pytest.mark.parametrize("fresh", [True, False], ids=["fresh", "legacy"])
 def test_put_writes_persists_task_path(
    tmp_path: Path, legacy_db: Path, fresh: bool
 ) -> None:
    db = tmp_path / "fresh.sqlite" if fresh else legacy_db
    with SqliteSaver.from_conn_string(str(db)) as saver:
        config = saver.put(
            {"configurable": {"thread_id": "t", "checkpoint_ns": ""}},
            empty_checkpoint(),
            {},
            {},
        )
        saver.put_writes(config, [("ch", "v")], "task-1", "~__pregel_pull, node")
        stored = saver.conn.execute(
            "SELECT task_path FROM writes WHERE task_id = 'task-1'"
        ).fetchall()
    assert stored == [("~__pregel_pull, node",)]
 async def test_async_setup_migrates_legacy_writes_table_repeatably(
    legacy_db: Path,
 ) -> None:
    for _ in range(2):
        async with AsyncSqliteSaver.from_conn_string(str(legacy_db)) as saver:
            await saver.setup()
            config = await saver.aput(
                {"configurable": {"thread_id": "t", "checkpoint_ns": ""}},
                empty_checkpoint(),
                {},
                {},
            )
            await saver.aput_writes(
                config, [("ch", "v")], "task-1", "~__pregel_pull, node"
            )
    async with aiosqlite.connect(legacy_db) as conn:
        async with conn.execute(
            "SELECT DISTINCT task_id, task_path FROM writes ORDER BY task_id"
        ) as cur:
            assert await cur.fetchall() == [
                ("old-task", ""),
                ("task-1", "~__pregel_pull, node"),
            ]
@@ -26,16 +26,16 @@ wheels = [
 [[package]]
 name = "anyio"
-version = "4.14.2"
+version = "4.12.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "exceptiongroup", marker = "python_full_version < '3.11'" },
    { name = "idna" },
    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/61/cc/a381afa6efea9f496eff839d4a6a1aed3bfafc7b3ab4b0d1b243a12573dd/anyio-4.14.2.tar.gz", hash = "sha256:cfa139f3ed1a23ee8f88a145ddb5ac7605b8bbfd8592baacd7ce3d8bb4313c7f", size = 260176, upload-time = "2026-07-12T20:29:07.082Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/96/f0/5eb65b2bb0d09ac6776f2eb54adee6abe8228ea05b20a5ad0e4945de8aac/anyio-4.12.1.tar.gz", hash = "sha256:41cfcc3a4c85d3f05c932da7c26d0201ac36f72abd4435ba90d0464a3ffed703", size = 228685, upload-time = "2026-01-06T11:45:21.246Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/da/35/f2287558c17e29fafc8ef3daf819bb9834061cfa43bff8014f7df7f63bdc/anyio-4.14.2-py3-none-any.whl", hash = "sha256:9f505dda5ac9f0c8309b5e8bd445a8c2bf7246f3ce950121e45ea15bc41d1494", size = 125813, upload-time = "2026-07-12T20:29:05.763Z" },
+    { url = "https://files.pythonhosted.org/packages/38/0e/27be9fdef66e72d64c0cdc3cc2823101b80585f8119b5c112c2e8f5f7dab/anyio-4.12.1-py3-none-any.whl", hash = "sha256:d405828884fc140aa80a3c667b8beed277f1dfedec42ba031bd6ac3db606ab6c", size = 113592, upload-time = "2026-01-06T11:45:19.497Z" },
 ]
 [[package]]
@@ -162,13 +162,6 @@ class DeltaChannelHistory(TypedDict):
      Always present; possibly empty. Already filtered to one channel.
      Writes stored at the target checkpoint itself are pending for the
      next super-step and are excluded.
      Within a single checkpoint, writes are ordered by
      `(task_path, task_id, idx)`: the order `apply_writes` applied them in
      live. `task_id` is a hash of the path, so ordering by it permutes
      parallel tasks writing one channel, and reducers need not be
      order-invariant. Writes stored without a `task_path` (graph input, or
      rows predating the column) sort first.
    * `seed` — the stored value at the nearest ancestor whose
      `channel_values[ch]` is populated. Omitted if the walk reached the
      root without finding any stored value (consumer treats absence as
@@ -618,11 +611,6 @@ class BaseCheckpointSaver(Generic[V]):
        `PostgresSaver`) override for performance; the return contract is
        fixed here.
        `PendingWrite` carries no `task_path`, so this default replays each
        checkpoint's writes in `get_tuple`'s `pending_writes` order. Savers
        that do not return `pending_writes` ordered by
        `(task_path, task_id, idx)` must override it.
        Args:
            config: Configuration identifying the target checkpoint.
            channels: Channel names to walk for. Empty → empty mapping.
@@ -199,8 +199,8 @@ class InMemorySaver(
                    terminated_here.add(ch)
            step_writes = self.writes.get((thread_id, checkpoint_ns, cp_id), {})
-            for _, (tid, ch, serialized, _) in sorted(
+            for (_task_id, _idx), (tid, ch, serialized, _) in sorted(
-                step_writes.items(), key=lambda kv: (kv[1][3], kv[0]), reverse=True
+                step_writes.items(), reverse=True
            ):
                if ch not in remaining:
                    continue
@@ -19,16 +19,16 @@ wheels = [
 [[package]]
 name = "anyio"
-version = "4.14.2"
+version = "4.12.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "exceptiongroup", marker = "python_full_version < '3.11'" },
    { name = "idna" },
    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/61/cc/a381afa6efea9f496eff839d4a6a1aed3bfafc7b3ab4b0d1b243a12573dd/anyio-4.14.2.tar.gz", hash = "sha256:cfa139f3ed1a23ee8f88a145ddb5ac7605b8bbfd8592baacd7ce3d8bb4313c7f", size = 260176, upload-time = "2026-07-12T20:29:07.082Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/96/f0/5eb65b2bb0d09ac6776f2eb54adee6abe8228ea05b20a5ad0e4945de8aac/anyio-4.12.1.tar.gz", hash = "sha256:41cfcc3a4c85d3f05c932da7c26d0201ac36f72abd4435ba90d0464a3ffed703", size = 228685, upload-time = "2026-01-06T11:45:21.246Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/da/35/f2287558c17e29fafc8ef3daf819bb9834061cfa43bff8014f7df7f63bdc/anyio-4.14.2-py3-none-any.whl", hash = "sha256:9f505dda5ac9f0c8309b5e8bd445a8c2bf7246f3ce950121e45ea15bc41d1494", size = 125813, upload-time = "2026-07-12T20:29:05.763Z" },
+    { url = "https://files.pythonhosted.org/packages/38/0e/27be9fdef66e72d64c0cdc3cc2823101b80585f8119b5c112c2e8f5f7dab/anyio-4.12.1-py3-none-any.whl", hash = "sha256:d405828884fc140aa80a3c667b8beed277f1dfedec42ba031bd6ac3db606ab6c", size = 113592, upload-time = "2026-01-06T11:45:19.497Z" },
 ]
 [[package]]
@@ -0,0 +1,285 @@
 # This file is automatically @generated by Poetry 2.0.0 and should not be changed by hand.
 [[package]]
 name = "anyio"
 version = "4.4.0"
 description = "High level compatibility layer for multiple asynchronous event loop implementations"
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 files = [
    {file = "anyio-4.4.0-py3-none-any.whl", hash = "sha256:c1b2d8f46a8a812513012e1107cb0e68c17159a7a594208005a57dc776e1bdc7"},
    {file = "anyio-4.4.0.tar.gz", hash = "sha256:5aadc6a1bbb7cdb0bede386cac5e2940f5e2ff3aa20277e991cf028e0585ce94"},
 ]
 [package.dependencies]
 exceptiongroup = {version = ">=1.0.2", markers = "python_version < \"3.11\""}
 idna = ">=2.8"
 sniffio = ">=1.1"
 typing-extensions = {version = ">=4.1", markers = "python_version < \"3.11\""}
 [package.extras]
 doc = ["Sphinx (>=7)", "packaging", "sphinx-autodoc-typehints (>=1.2.0)", "sphinx-rtd-theme"]
 test = ["anyio[trio]", "coverage[toml] (>=7)", "exceptiongroup (>=1.2.0)", "hypothesis (>=4.0)", "psutil (>=5.9)", "pytest (>=7.0)", "pytest-mock (>=3.6.1)", "trustme", "uvloop (>=0.17)"]
 trio = ["trio (>=0.23)"]
 [[package]]
 name = "certifi"
 version = "2024.7.4"
 description = "Python package for providing Mozilla's CA Bundle."
 optional = false
 python-versions = ">=3.6"
 groups = ["main"]
 files = [
    {file = "certifi-2024.7.4-py3-none-any.whl", hash = "sha256:c198e21b1289c2ab85ee4e67bb4b4ef3ead0892059901a8d5b622f24a1101e90"},
    {file = "certifi-2024.7.4.tar.gz", hash = "sha256:5a1e7645bc0ec61a09e26c36f6106dd4cf40c6db3a1fb6352b0244e7fb057c7b"},
 ]
 [[package]]
 name = "click"
 version = "8.1.7"
 description = "Composable command line interface toolkit"
 optional = false
 python-versions = ">=3.7"
 groups = ["main"]
 files = [
    {file = "click-8.1.7-py3-none-any.whl", hash = "sha256:ae74fb96c20a0277a1d615f1e4d73c8414f5a98db8b799a7931d1582f3390c28"},
    {file = "click-8.1.7.tar.gz", hash = "sha256:ca9853ad459e787e2192211578cc907e7594e294c7ccc834310722b41b9ca6de"},
 ]
 [package.dependencies]
 colorama = {version = "*", markers = "platform_system == \"Windows\""}
 [[package]]
 name = "colorama"
 version = "0.4.6"
 description = "Cross-platform colored terminal text."
 optional = false
 python-versions = "!=3.0.*,!=3.1.*,!=3.2.*,!=3.3.*,!=3.4.*,!=3.5.*,!=3.6.*,>=2.7"
 groups = ["main"]
 markers = "platform_system == \"Windows\""
 files = [
    {file = "colorama-0.4.6-py2.py3-none-any.whl", hash = "sha256:4f1d9991f5acc0ca119f9d443620b77f9d6b33703e51011c16baf57afb285fc6"},
    {file = "colorama-0.4.6.tar.gz", hash = "sha256:08695f5cb7ed6e0531a20572697297273c47b8cae5a63ffc6d6ed5c201be6e44"},
 ]
 [[package]]
 name = "exceptiongroup"
 version = "1.2.1"
 description = "Backport of PEP 654 (exception groups)"
 optional = false
 python-versions = ">=3.7"
 groups = ["main"]
 markers = "python_version < \"3.11\""
 files = [
    {file = "exceptiongroup-1.2.1-py3-none-any.whl", hash = "sha256:5258b9ed329c5bbdd31a309f53cbfb0b155341807f6ff7606a1e801a891b29ad"},
    {file = "exceptiongroup-1.2.1.tar.gz", hash = "sha256:a4785e48b045528f5bfe627b6ad554ff32def154f42372786903b7abcfe1aa16"},
 ]
 [package.extras]
 test = ["pytest (>=6)"]
 [[package]]
 name = "h11"
 version = "0.16.0"
 description = "A pure-Python, bring-your-own-I/O implementation of HTTP/1.1"
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 files = [
    {file = "h11-0.16.0-py3-none-any.whl", hash = "sha256:63cf8bbe7522de3bf65932fda1d9c2772064ffb3dae62d55932da54b31cb6c86"},
    {file = "h11-0.16.0.tar.gz", hash = "sha256:4e35b956cf45792e4caa5885e69fba00bdbc6ffafbfa020300e549b208ee5ff1"},
 ]
 [[package]]
 name = "httpcore"
 version = "1.0.9"
 description = "A minimal low-level HTTP client."
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 files = [
    {file = "httpcore-1.0.9-py3-none-any.whl", hash = "sha256:2d400746a40668fc9dec9810239072b40b4484b640a8c38fd654a024c7a1bf55"},
    {file = "httpcore-1.0.9.tar.gz", hash = "sha256:6e34463af53fd2ab5d807f399a9b45ea31c3dfa2276f15a2c3f00afff6e176e8"},
 ]
 [package.dependencies]
 certifi = "*"
 h11 = ">=0.16"
 [package.extras]
 asyncio = ["anyio (>=4.0,<5.0)"]
 http2 = ["h2 (>=3,<5)"]
 socks = ["socksio (==1.*)"]
 trio = ["trio (>=0.22.0,<1.0)"]
 [[package]]
 name = "httpx"
 version = "0.28.1"
 description = "The next generation HTTP client."
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 files = [
    {file = "httpx-0.28.1-py3-none-any.whl", hash = "sha256:d909fcccc110f8c7faf814ca82a9a4d816bc5a6dbfea25d6591d6985b8ba59ad"},
    {file = "httpx-0.28.1.tar.gz", hash = "sha256:75e98c5f16b0f35b567856f597f06ff2270a374470a5c2392242528e3e3e42fc"},
 ]
 [package.dependencies]
 anyio = "*"
 certifi = "*"
 httpcore = "==1.*"
 idna = "*"
 [package.extras]
 brotli = ["brotli", "brotlicffi"]
 cli = ["click (==8.*)", "pygments (==2.*)", "rich (>=10,<14)"]
 http2 = ["h2 (>=3,<5)"]
 socks = ["socksio (==1.*)"]
 zstd = ["zstandard (>=0.18.0)"]
 [[package]]
 name = "httpx-sse"
 version = "0.4.0"
 description = "Consume Server-Sent Event (SSE) messages with HTTPX."
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 files = [
    {file = "httpx-sse-0.4.0.tar.gz", hash = "sha256:1e81a3a3070ce322add1d3529ed42eb5f70817f45ed6ec915ab753f961139721"},
    {file = "httpx_sse-0.4.0-py3-none-any.whl", hash = "sha256:f329af6eae57eaa2bdfd962b42524764af68075ea87370a2de920af5341e318f"},
 ]
 [[package]]
 name = "idna"
 version = "3.7"
 description = "Internationalized Domain Names in Applications (IDNA)"
 optional = false
 python-versions = ">=3.5"
 groups = ["main"]
 files = [
    {file = "idna-3.7-py3-none-any.whl", hash = "sha256:82fee1fc78add43492d3a1898bfa6d8a904cc97d8427f683ed8e798d07761aa0"},
    {file = "idna-3.7.tar.gz", hash = "sha256:028ff3aadf0609c1fd278d8ea3089299412a7a8b9bd005dd08b9f8285bcb5cfc"},
 ]
 [[package]]
 name = "langgraph-cli"
 version = "0.1.52"
 description = "CLI for interacting with LangGraph API"
 optional = false
 python-versions = "^3.9.0,<4.0"
 groups = ["main"]
 files = []
 develop = true
 [package.dependencies]
 click = "^8.1.7"
 [package.source]
 type = "directory"
 url = ".."
 [[package]]
 name = "langgraph-sdk"
 version = "0.1.29"
 description = "SDK for interacting with LangGraph API"
 optional = false
 python-versions = "^3.9.0,<4.0"
 groups = ["main"]
 files = []
 develop = true
 [package.dependencies]
 httpx = ">=0.25.2"
 httpx-sse = ">=0.4.0"
 orjson = ">=3.10.1"
 [package.source]
 type = "directory"
 url = "../../sdk-py"
 [[package]]
 name = "orjson"
 version = "3.10.5"
 description = "Fast, correct Python JSON library supporting dataclasses, datetimes, and numpy"
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 files = [
    {file = "orjson-3.10.5-cp310-cp310-macosx_10_15_x86_64.macosx_11_0_arm64.macosx_10_15_universal2.whl", hash = "sha256:545d493c1f560d5ccfc134803ceb8955a14c3fcb47bbb4b2fee0232646d0b932"},
    {file = "orjson-3.10.5-cp310-cp310-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:f4324929c2dd917598212bfd554757feca3e5e0fa60da08be11b4aa8b90013c1"},
    {file = "orjson-3.10.5-cp310-cp310-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:8c13ca5e2ddded0ce6a927ea5a9f27cae77eee4c75547b4297252cb20c4d30e6"},
    {file = "orjson-3.10.5-cp310-cp310-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:b6c8e30adfa52c025f042a87f450a6b9ea29649d828e0fec4858ed5e6caecf63"},
    {file = "orjson-3.10.5-cp310-cp310-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:338fd4f071b242f26e9ca802f443edc588fa4ab60bfa81f38beaedf42eda226c"},
    {file = "orjson-3.10.5-cp310-cp310-musllinux_1_2_aarch64.whl", hash = "sha256:6970ed7a3126cfed873c5d21ece1cd5d6f83ca6c9afb71bbae21a0b034588d96"},
    {file = "orjson-3.10.5-cp310-cp310-musllinux_1_2_x86_64.whl", hash = "sha256:235dadefb793ad12f7fa11e98a480db1f7c6469ff9e3da5e73c7809c700d746b"},
    {file = "orjson-3.10.5-cp310-none-win32.whl", hash = "sha256:be79e2393679eda6a590638abda16d167754393f5d0850dcbca2d0c3735cebe2"},
    {file = "orjson-3.10.5-cp310-none-win_amd64.whl", hash = "sha256:c4a65310ccb5c9910c47b078ba78e2787cb3878cdded1702ac3d0da71ddc5228"},
    {file = "orjson-3.10.5-cp311-cp311-macosx_10_15_x86_64.macosx_11_0_arm64.macosx_10_15_universal2.whl", hash = "sha256:cdf7365063e80899ae3a697def1277c17a7df7ccfc979990a403dfe77bb54d40"},
    {file = "orjson-3.10.5-cp311-cp311-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:6b68742c469745d0e6ca5724506858f75e2f1e5b59a4315861f9e2b1df77775a"},
    {file = "orjson-3.10.5-cp311-cp311-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:7d10cc1b594951522e35a3463da19e899abe6ca95f3c84c69e9e901e0bd93d38"},
    {file = "orjson-3.10.5-cp311-cp311-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:dcbe82b35d1ac43b0d84072408330fd3295c2896973112d495e7234f7e3da2e1"},
    {file = "orjson-3.10.5-cp311-cp311-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:10c0eb7e0c75e1e486c7563fe231b40fdd658a035ae125c6ba651ca3b07936f5"},
    {file = "orjson-3.10.5-cp311-cp311-musllinux_1_2_aarch64.whl", hash = "sha256:53ed1c879b10de56f35daf06dbc4a0d9a5db98f6ee853c2dbd3ee9d13e6f302f"},
    {file = "orjson-3.10.5-cp311-cp311-musllinux_1_2_x86_64.whl", hash = "sha256:099e81a5975237fda3100f918839af95f42f981447ba8f47adb7b6a3cdb078fa"},
    {file = "orjson-3.10.5-cp311-none-win32.whl", hash = "sha256:1146bf85ea37ac421594107195db8bc77104f74bc83e8ee21a2e58596bfb2f04"},
    {file = "orjson-3.10.5-cp311-none-win_amd64.whl", hash = "sha256:36a10f43c5f3a55c2f680efe07aa93ef4a342d2960dd2b1b7ea2dd764fe4a37c"},
    {file = "orjson-3.10.5-cp312-cp312-macosx_10_15_x86_64.macosx_11_0_arm64.macosx_10_15_universal2.whl", hash = "sha256:68f85ecae7af14a585a563ac741b0547a3f291de81cd1e20903e79f25170458f"},
    {file = "orjson-3.10.5-cp312-cp312-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:28afa96f496474ce60d3340fe8d9a263aa93ea01201cd2bad844c45cd21f5268"},
    {file = "orjson-3.10.5-cp312-cp312-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:9cd684927af3e11b6e754df80b9ffafd9fb6adcaa9d3e8fdd5891be5a5cad51e"},
    {file = "orjson-3.10.5-cp312-cp312-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:3d21b9983da032505f7050795e98b5d9eee0df903258951566ecc358f6696969"},
    {file = "orjson-3.10.5-cp312-cp312-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:1ad1de7fef79736dde8c3554e75361ec351158a906d747bd901a52a5c9c8d24b"},
    {file = "orjson-3.10.5-cp312-cp312-musllinux_1_2_aarch64.whl", hash = "sha256:2d97531cdfe9bdd76d492e69800afd97e5930cb0da6a825646667b2c6c6c0211"},
    {file = "orjson-3.10.5-cp312-cp312-musllinux_1_2_x86_64.whl", hash = "sha256:d69858c32f09c3e1ce44b617b3ebba1aba030e777000ebdf72b0d8e365d0b2b3"},
    {file = "orjson-3.10.5-cp312-none-win32.whl", hash = "sha256:64c9cc089f127e5875901ac05e5c25aa13cfa5dbbbd9602bda51e5c611d6e3e2"},
    {file = "orjson-3.10.5-cp312-none-win_amd64.whl", hash = "sha256:b2efbd67feff8c1f7728937c0d7f6ca8c25ec81373dc8db4ef394c1d93d13dc5"},
    {file = "orjson-3.10.5-cp38-cp38-macosx_10_15_x86_64.macosx_11_0_arm64.macosx_10_15_universal2.whl", hash = "sha256:03b565c3b93f5d6e001db48b747d31ea3819b89abf041ee10ac6988886d18e01"},
    {file = "orjson-3.10.5-cp38-cp38-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:584c902ec19ab7928fd5add1783c909094cc53f31ac7acfada817b0847975f26"},
    {file = "orjson-3.10.5-cp38-cp38-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:5a35455cc0b0b3a1eaf67224035f5388591ec72b9b6136d66b49a553ce9eb1e6"},
    {file = "orjson-3.10.5-cp38-cp38-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:1670fe88b116c2745a3a30b0f099b699a02bb3482c2591514baf5433819e4f4d"},
    {file = "orjson-3.10.5-cp38-cp38-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:185c394ef45b18b9a7d8e8f333606e2e8194a50c6e3c664215aae8cf42c5385e"},
    {file = "orjson-3.10.5-cp38-cp38-musllinux_1_2_aarch64.whl", hash = "sha256:ca0b3a94ac8d3886c9581b9f9de3ce858263865fdaa383fbc31c310b9eac07c9"},
    {file = "orjson-3.10.5-cp38-cp38-musllinux_1_2_x86_64.whl", hash = "sha256:dfc91d4720d48e2a709e9c368d5125b4b5899dced34b5400c3837dadc7d6271b"},
    {file = "orjson-3.10.5-cp38-none-win32.whl", hash = "sha256:c05f16701ab2a4ca146d0bca950af254cb7c02f3c01fca8efbbad82d23b3d9d4"},
    {file = "orjson-3.10.5-cp38-none-win_amd64.whl", hash = "sha256:8a11d459338f96a9aa7f232ba95679fc0c7cedbd1b990d736467894210205c09"},
    {file = "orjson-3.10.5-cp39-cp39-macosx_10_15_x86_64.macosx_11_0_arm64.macosx_10_15_universal2.whl", hash = "sha256:85c89131d7b3218db1b24c4abecea92fd6c7f9fab87441cfc342d3acc725d807"},
    {file = "orjson-3.10.5-cp39-cp39-manylinux_2_17_aarch64.manylinux2014_aarch64.whl", hash = "sha256:fb66215277a230c456f9038d5e2d84778141643207f85336ef8d2a9da26bd7ca"},
    {file = "orjson-3.10.5-cp39-cp39-manylinux_2_17_ppc64le.manylinux2014_ppc64le.whl", hash = "sha256:51bbcdea96cdefa4a9b4461e690c75ad4e33796530d182bdd5c38980202c134a"},
    {file = "orjson-3.10.5-cp39-cp39-manylinux_2_17_s390x.manylinux2014_s390x.whl", hash = "sha256:dbead71dbe65f959b7bd8cf91e0e11d5338033eba34c114f69078d59827ee139"},
    {file = "orjson-3.10.5-cp39-cp39-manylinux_2_17_x86_64.manylinux2014_x86_64.whl", hash = "sha256:5df58d206e78c40da118a8c14fc189207fffdcb1f21b3b4c9c0c18e839b5a214"},
    {file = "orjson-3.10.5-cp39-cp39-musllinux_1_2_aarch64.whl", hash = "sha256:c4057c3b511bb8aef605616bd3f1f002a697c7e4da6adf095ca5b84c0fd43595"},
    {file = "orjson-3.10.5-cp39-cp39-musllinux_1_2_x86_64.whl", hash = "sha256:b39e006b00c57125ab974362e740c14a0c6a66ff695bff44615dcf4a70ce2b86"},
    {file = "orjson-3.10.5-cp39-none-win32.whl", hash = "sha256:eded5138cc565a9d618e111c6d5c2547bbdd951114eb822f7f6309e04db0fb47"},
    {file = "orjson-3.10.5-cp39-none-win_amd64.whl", hash = "sha256:cc28e90a7cae7fcba2493953cff61da5a52950e78dc2dacfe931a317ee3d8de7"},
    {file = "orjson-3.10.5.tar.gz", hash = "sha256:7a5baef8a4284405d96c90c7c62b755e9ef1ada84c2406c24a9ebec86b89f46d"},
 ]
 [[package]]
 name = "sniffio"
 version = "1.3.1"
 description = "Sniff out which async library your code is running under"
 optional = false
 python-versions = ">=3.7"
 groups = ["main"]
 files = [
    {file = "sniffio-1.3.1-py3-none-any.whl", hash = "sha256:2f6da418d1f1e0fddd844478f41680e794e6051915791a034ff65e5f100525a2"},
    {file = "sniffio-1.3.1.tar.gz", hash = "sha256:f4324edc670a0f49750a81b895f35c3adb843cca46f0530f79fc1babb23789dc"},
 ]
 [[package]]
 name = "typing-extensions"
 version = "4.12.2"
 description = "Backported and Experimental Type Hints for Python 3.8+"
 optional = false
 python-versions = ">=3.8"
 groups = ["main"]
 markers = "python_version < \"3.11\""
 files = [
    {file = "typing_extensions-4.12.2-py3-none-any.whl", hash = "sha256:04e5ca0351e0f3f85c6853954072df659d0d13fac324d0072316b67d7794700d"},
    {file = "typing_extensions-4.12.2.tar.gz", hash = "sha256:1a7ead55c7e559dd4dee8856e3a88b41225abfe1ce8df57b7c13915fe121ffb8"},
 ]
 [metadata]
 lock-version = "2.1"
 python-versions = "^3.9.0,<4.0"
 content-hash = "ec5109729f30d2033a10a10e8f8d3ed94c7d96d5d31025b4815b0123664bb063"
@@ -1,18 +1,12 @@
 import asyncio
 import signal
 import sys
-from collections.abc import Callable, Coroutine
+from collections.abc import Callable
 from contextlib import contextmanager
-from typing import Any, Protocol, TypeVar, cast
+from typing import cast
 import click.exceptions
 _T = TypeVar("_T")
 class CommandRunner(Protocol):
    def run(self, coro: Coroutine[Any, Any, _T]) -> _T: ...
@contextmanager
 def Runner():
@@ -2,86 +2,11 @@
 from __future__ import annotations
-from dataclasses import dataclass
+from typing import Any
 from typing import Any, Literal
 from urllib.parse import urlparse
 import click
 import httpx
 CLOUD_CONTROL_PLANE_URL = "https://api.host.langchain.com"
 CLOUD_DASHBOARD_URL = "https://smith.langchain.com"
 CLOUD_DOMAIN = "langchain.com"
 CLOUD_API_HOST = "api.smith.langchain.com"
 CLOUD_CONTROL_PLANE_HOST = "api.host.langchain.com"
 CLOUD_DASHBOARD_HOST = "smith.langchain.com"
 CONTROL_PLANE_PATH = "/api-host"
 LANGSMITH_API_PATHS = ("/api/v1", "/api")
 LOCAL_HOSTNAMES = ("localhost", "127.0.0.1")
 SourceName = Literal["internal_docker", "internal_source", "external_docker"]
@dataclass(frozen=True, slots=True)
 class ControlPlaneEndpoints:
    control_plane_url: str
    dashboard_url: str
    @classmethod
    def resolve(
        cls, host_url: str | None, langsmith_endpoint: str | None
    ) -> ControlPlaneEndpoints:
        if host_url:
            return cls.from_control_plane_url(host_url)
        if langsmith_endpoint:
            return cls.from_langsmith_endpoint(langsmith_endpoint)
        return cls(CLOUD_CONTROL_PLANE_URL, CLOUD_DASHBOARD_URL)
    @classmethod
    def from_control_plane_url(cls, url: str) -> ControlPlaneEndpoints:
        control_plane_url = url.rstrip("/")
        hostname = urlparse(control_plane_url).hostname or ""
        if control_plane_url.endswith(CONTROL_PLANE_PATH):
            return cls(control_plane_url, control_plane_url[: -len(CONTROL_PLANE_PATH)])
        if hostname in LOCAL_HOSTNAMES:
            return cls(control_plane_url, control_plane_url)
        return cls(control_plane_url, _cloud_dashboard_for(hostname))
    @classmethod
    def from_langsmith_endpoint(cls, endpoint: str) -> ControlPlaneEndpoints:
        parsed = urlparse(endpoint.rstrip("/"))
        hostname = parsed.hostname or ""
        if _is_cloud_host(hostname):
            return cls.from_control_plane_url(
                f"https://{_cloud_control_plane_host_for(hostname)}"
            )
        root = f"{parsed.scheme}://{parsed.netloc}{_without_api_path(parsed.path)}"
        return cls(f"{root}{CONTROL_PLANE_PATH}", root)
 def _is_cloud_host(hostname: str) -> bool:
    return hostname == CLOUD_DOMAIN or hostname.endswith(f".{CLOUD_DOMAIN}")
 def _cloud_control_plane_host_for(langsmith_api_host: str) -> str:
    if langsmith_api_host.endswith(f".{CLOUD_API_HOST}"):
        region = langsmith_api_host[: -len(CLOUD_API_HOST)]
        return f"{region}{CLOUD_CONTROL_PLANE_HOST}"
    return CLOUD_CONTROL_PLANE_HOST
 def _cloud_dashboard_for(control_plane_host: str) -> str:
    if control_plane_host.endswith(f".{CLOUD_CONTROL_PLANE_HOST}"):
        region = control_plane_host[: -len(CLOUD_CONTROL_PLANE_HOST) - 1]
        return f"https://{region}.{CLOUD_DASHBOARD_HOST}"
    return CLOUD_DASHBOARD_URL
 def _without_api_path(path: str) -> str:
    for api_path in LANGSMITH_API_PATHS:
        if path.endswith(api_path):
            return path[: -len(api_path)]
    return path
 class HostBackendError(click.ClickException):
    """Raised when the host backend returns an error response."""
@@ -99,11 +24,10 @@ class HostBackendClient:
        base_url: str,
        api_key: str,
        tenant_id: str | None = None,
        *,
        transport: httpx.BaseTransport | None = None,
    ):
        if not base_url:
            raise click.UsageError("Host backend URL is required")
        transport = httpx.HTTPTransport(retries=3)
        headers: dict[str, str] = {
            "X-Api-Key": api_key,
            "Accept": "application/json",
@@ -114,17 +38,10 @@ class HostBackendClient:
        self._client = httpx.Client(
            base_url=self._base_url,
            headers=headers,
-            transport=transport or httpx.HTTPTransport(retries=3),
+            transport=transport,
            timeout=30,
        )
    @property
    def base_url(self) -> str:
        return self._base_url
    def set_tenant(self, tenant_id: str) -> None:
        self._client.headers["X-Tenant-ID"] = tenant_id
    def _request(
        self,
        method: str,
@@ -155,43 +72,30 @@ class HostBackendClient:
    def create_deployment(
        self,
-        *,
+        name: str,
-        name: str | None,
+        deployment_type: str,
-        source: SourceName,
+        source: str,
-        source_config: dict[str, object],
+        config_path: str | None = None,
        source_revision_config: dict[str, object],
        secrets: list[dict[str, str]] | None = None,
        agent: dict[str, str] | None = None,
    ) -> dict[str, Any]:
        """Create a deployment."""
        payload: dict[str, Any] = {
            "name": name,
            "source": source,
-            "source_config": source_config,
+            "source_config": {"deployment_type": deployment_type},
-            "source_revision_config": source_revision_config,
+            "source_revision_config": {},
        }
-        if agent is not None:
+        if source == "internal_source" and config_path:
-            payload["agent"] = agent
+            payload["source_revision_config"]["langgraph_config_path"] = config_path
        else:
            payload["name"] = name
        if secrets is not None:
            payload["secrets"] = secrets
        return self._request("POST", "/v2/deployments", payload)
-    def list_deployments(
+    def list_deployments(self, name_contains: str = "") -> dict[str, Any]:
        self,
        name_contains: str = "",
        *,
        agent_id: str | None = None,
        agent_environment: str | None = None,
    ) -> dict[str, Any]:
        params = {"name_contains": name_contains}
        if agent_id is not None:
            params["agent_id"] = agent_id
        if agent_environment is not None:
            params["agent_environment"] = agent_environment
        return self._request(
            "GET",
            "/v2/deployments",
-            params=params,
+            params={"name_contains": name_contains},
        )
    def get_deployment(self, deployment_id: str) -> dict[str, Any]:
@@ -217,21 +121,22 @@ class HostBackendClient:
        self,
        deployment_id: str,
        image_uri: str,
        *,
        revision_source: SourceName | None,
        secrets: list[dict[str, str]] | None = None,
        tracked_packages: list[str] | None = None,
    ) -> dict[str, Any]:
        payload: dict[str, Any] = {
            "revision_source": "internal_docker",
            "source_revision_config": {"image_uri": image_uri},
        }
        if revision_source is not None:
            payload["revision_source"] = revision_source
        if tracked_packages:
            payload["tracked_packages"] = tracked_packages
        if secrets is not None:
            payload["secrets"] = secrets
-        return self._request("PATCH", f"/v2/deployments/{deployment_id}", payload)
+        return self._request(
            "PATCH",
            f"/v2/deployments/{deployment_id}",
            payload,
        )
    def update_deployment_internal_source(
        self,
@@ -1,35 +0,0 @@
 from __future__ import annotations
 from dataclasses import dataclass, replace
 DIGEST_SEPARATOR = "@sha256:"
 DIGEST_MARKER = "@"
 TAG_SEPARATOR = ":"
 PATH_SEPARATOR = "/"
@dataclass(frozen=True, slots=True)
 class ImageReference:
    repository: str
    tag: str | None = None
    @classmethod
    def parse(cls, reference: str) -> ImageReference:
        if DIGEST_MARKER in reference:
            raise ValueError(f"{reference!r} carries a digest and cannot be tagged")
        path_start = reference.rfind(PATH_SEPARATOR) + 1
        name, separator, tag = reference[path_start:].partition(TAG_SEPARATOR)
        if not separator:
            return cls(reference)
        return cls(reference[:path_start] + name, tag)
    def with_tag(self, tag: str) -> ImageReference:
        return replace(self, tag=tag)
    def matches_digest(self, repo_digest: str) -> bool:
        return repo_digest.startswith(f"{self.repository}{DIGEST_SEPARATOR}")
    def __str__(self) -> str:
        if self.tag is None:
            return self.repository
        return f"{self.repository}{TAG_SEPARATOR}{self.tag}"
@@ -1,654 +0,0 @@
 import asyncio
 import json
 from collections.abc import Callable, Iterator
 from contextlib import contextmanager
 from dataclasses import dataclass, field
 from pathlib import Path
 import click.exceptions
 import httpx
 import pytest
 from click.testing import CliRunner, Result
 import langgraph_cli.archive as archive_module
 import langgraph_cli.deploy as deploy_module
 from langgraph_cli.cli import cli
 from langgraph_cli.host_backend import HostBackendClient
 from langgraph_cli.image_reference import ImageReference
 CONTROL_PLANE_URL = "https://control-plane.example.com"
 REGISTRY_URL = "https://registry.example.com/team"
 PUSH_TOKEN = "push-token"
 PUSHED_IMAGE = "registry.example.com/team/my-app:latest"
 PUSHED_DIGEST = "registry.example.com/team/my-app@sha256:abc123"
 PUSH_REPOSITORY = "registry.example.com/team/agent"
 EXTERNAL_IMAGE = f"{PUSH_REPOSITORY}:latest"
 EXTERNAL_DIGEST = f"{PUSH_REPOSITORY}@sha256:abc123"
 LISTENER_REQUIRED = (
    "Source configuration error: 'source_config.listener_id' is required for "
    "workspace with available listener IDs: ['listener-1']"
 )
 CREATED_ID = "dep-created"
 TRACKED_PACKAGES = ["langgraph:1.0.0"]
 SIGNED_UPLOAD_URL = "https://storage.example.com/signed"
 ARCHIVE = ("/tmp/src.tgz", 2048, "langgraph.json")
 OBJECT_PATH = "tarballs/src.tgz"
 PLATFORM_FORMAT = "{{.Os}}/{{.Architecture}}"
 DIGESTS_FORMAT = "{{json .RepoDigests}}"
 NOT_A_CLI_DEPLOYMENT = (
    "push token is only available for 'internal_docker' source deployments"
 )
 LIST_DEPLOYMENTS = "GET /v2/deployments"
 CREATE_DEPLOYMENT = "POST /v2/deployments"
 def _push_token(deployment_id: str) -> str:
    return f"POST /v2/deployments/{deployment_id}/push-token"
 def _upload_url(deployment_id: str) -> str:
    return f"POST /v2/deployments/{deployment_id}/upload-url"
 def _patch(deployment_id: str) -> str:
    return f"PATCH /v2/deployments/{deployment_id}"
 def _get(deployment_id: str) -> str:
    return f"GET /v2/deployments/{deployment_id}"
@dataclass
 class ControlPlaneDouble:
    timeline: list[str]
    existing_deployments: list[dict] = field(default_factory=list)
    push_token_status: int = 200
    create_error: str | None = None
    bodies: dict[str, dict] = field(default_factory=dict)
    def handle(self, request: httpx.Request) -> httpx.Response:
        route = f"{request.method} {request.url.path}"
        self.timeline.append(route)
        if request.content:
            self.bodies[route] = json.loads(request.content)
        return self._respond(request.method, request.url.path)
    def _respond(self, method: str, path: str) -> httpx.Response:
        if (method, path) == ("GET", "/v2/deployments"):
            return httpx.Response(200, json={"resources": self.existing_deployments})
        if (method, path) == ("POST", "/v2/deployments"):
            if self.create_error is not None:
                return httpx.Response(400, text=self.create_error)
            return httpx.Response(201, json={"id": CREATED_ID, "tenant_id": "tenant-1"})
        if path.endswith("/push-token"):
            if self.push_token_status != 200:
                return httpx.Response(self.push_token_status, text=NOT_A_CLI_DEPLOYMENT)
            return httpx.Response(
                200, json={"token": PUSH_TOKEN, "registry_url": REGISTRY_URL}
            )
        if path.endswith("/upload-url"):
            return httpx.Response(
                200, json={"upload_url": SIGNED_UPLOAD_URL, "object_path": OBJECT_PATH}
            )
        if method == "PATCH":
            return httpx.Response(200, json={"tenant_id": "tenant-1"})
        if method == "GET":
            deployment_id = path.rsplit("/", 1)[-1]
            return httpx.Response(
                200,
                json=next(
                    d for d in self.existing_deployments if d["id"] == deployment_id
                ),
            )
        raise AssertionError(f"unexpected control plane call: {method} {path}")
    def client_factory(self) -> Callable[..., HostBackendClient]:
        transport = httpx.MockTransport(self.handle)
        def make(
            host_url: str, api_key: str, tenant_id: str | None = None
        ) -> HostBackendClient:
            return HostBackendClient(host_url, api_key, tenant_id, transport=transport)
        return make
@dataclass
 class DockerCommand:
    args: tuple[str, ...]
    kwargs: dict
@dataclass
 class DockerDouble:
    timeline: list[str]
    failing_pushes: int = 0
    builds: list[dict] = field(default_factory=list)
    commands: list[DockerCommand] = field(default_factory=list)
    def verbs(self) -> list[str]:
        return [event for event in self.timeline if event.startswith("docker ")]
    def command(self, verb: str) -> DockerCommand:
        return next(c for c in self.commands if verb in c.args)
    def build_docker_image(
        self,
        runner: object,
        set_message: Callable[[str], None],
        config: Path,
        config_json: dict,
        base_image: str | None,
        api_version: str | None,
        pull: bool,
        tag: str,
        passthrough: tuple[str, ...] = (),
        install_command: str | None = None,
        build_command: str | None = None,
        docker_command: tuple[str, ...] | None = None,
        extra_flags: tuple[str, ...] = (),
        verbose: bool = True,
    ) -> None:
        self.timeline.append("docker build")
        self.builds.append(
            {
                "tag": tag,
                "docker_command": tuple(docker_command or ("docker", "build")),
                "extra_flags": tuple(extra_flags),
            }
        )
    async def subp_exec(
        self, *args: str, **kwargs: object
    ) -> tuple[str | None, str | None]:
        self.commands.append(DockerCommand(args=args, kwargs=kwargs))
        self.timeline.append(f"docker {self._verb(args)}")
        if "push" in args and self.failing_pushes > 0:
            self.failing_pushes -= 1
            raise click.exceptions.Exit(1)
        if PLATFORM_FORMAT in args:
            return "linux/amd64\n", None
        if DIGESTS_FORMAT in args:
            repository = ImageReference.parse(args[-1]).repository
            return json.dumps([f"{repository}@sha256:abc123"]), None
        return None, None
    @staticmethod
    def _verb(args: tuple[str, ...]) -> str:
        if PLATFORM_FORMAT in args:
            return "inspect-platform"
        if DIGESTS_FORMAT in args:
            return "inspect-digest"
        return next(verb for verb in ("login", "tag", "push", "pull") if verb in args)
 class _AsyncioRunner:
    def run(self, coro):
        return asyncio.run(coro)
@contextmanager
 def _fake_runner() -> Iterator[_AsyncioRunner]:
    yield _AsyncioRunner()
@dataclass
 class DeployProject:
    control_plane: ControlPlaneDouble
    docker: DockerDouble
    timeline: list[str]
    uploads: list[tuple[str, str, int]]
    def run(self, *args: str) -> Result:
        return CliRunner().invoke(
            cli,
            [
                "deploy",
                "--api-key",
                "test-key",
                "--host-url",
                CONTROL_PLANE_URL,
                "--name",
                "my-app",
                "--no-input",
                "--no-wait",
                *args,
            ],
        )
@pytest.fixture
 def deploy_project(tmp_path: Path, monkeypatch: pytest.MonkeyPatch) -> DeployProject:
    (tmp_path / "langgraph.json").write_text(
        json.dumps({"graphs": {"agent": "agent.py:graph"}, "dependencies": ["."]})
    )
    monkeypatch.chdir(tmp_path)
    for name in ("LANGSMITH_TENANT_ID", "LANGSMITH_ENDPOINT", "LANGGRAPH_HOST_URL"):
        monkeypatch.delenv(name, raising=False)
    timeline: list[str] = []
    control_plane = ControlPlaneDouble(timeline)
    docker = DockerDouble(timeline)
    uploads: list[tuple[str, str, int]] = []
    @contextmanager
    def fake_create_archive(config_path: Path, config: dict) -> Iterator[tuple]:
        timeline.append("create_archive")
        yield ARCHIVE
    def fake_upload(signed_url: str, file_path: str, file_size: int) -> None:
        timeline.append("upload_archive")
        uploads.append((signed_url, file_path, file_size))
    monkeypatch.setattr(deploy_module, "_no_input", False)
    monkeypatch.setattr(deploy_module, "_emitter", None)
    monkeypatch.setattr(
        deploy_module, "HostBackendClient", control_plane.client_factory()
    )
    monkeypatch.setattr(deploy_module, "build_docker_image", docker.build_docker_image)
    monkeypatch.setattr(deploy_module, "subp_exec", docker.subp_exec)
    monkeypatch.setattr(deploy_module, "Runner", _fake_runner)
    monkeypatch.setattr(deploy_module, "can_build_locally", lambda: (True, None))
    monkeypatch.setattr(
        deploy_module,
        "find_tracked_packages",
        lambda config, config_json: TRACKED_PACKAGES,
    )
    monkeypatch.setattr(deploy_module.platform, "machine", lambda: "x86_64")
    monkeypatch.setattr(archive_module, "create_archive", fake_create_archive)
    monkeypatch.setattr(deploy_module, "_upload_to_gcs", fake_upload)
    return DeployProject(control_plane, docker, timeline, uploads)
 def test_first_local_deploy_creates_then_builds_pushes_and_updates_in_order(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run("--no-remote")
    assert result.exit_code == 0, result.output
    assert deploy_project.timeline == [
        LIST_DEPLOYMENTS,
        CREATE_DEPLOYMENT,
        "docker build",
        _push_token(CREATED_ID),
        "docker login",
        "docker tag",
        "docker push",
        "docker inspect-digest",
        _patch(CREATED_ID),
    ]
    assert "Deployment updated" in result.output
 def test_first_local_deploy_creates_an_internal_docker_deployment(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.run("--no-remote")
    assert deploy_project.control_plane.bodies[CREATE_DEPLOYMENT] == {
        "name": "my-app",
        "source": "internal_docker",
        "source_config": {"deployment_type": "dev"},
        "source_revision_config": {},
        "secrets": [],
    }
@pytest.mark.parametrize(
    ("machine", "expected_command", "expected_flags"),
    [
        pytest.param(
            "arm64",
            ("docker", "buildx", "build"),
            ("--platform", "linux/amd64", "--load", "--progress=quiet"),
            id="apple_silicon_cross_builds_for_linux_amd64",
        ),
        pytest.param(
            "x86_64",
            ("docker", "build"),
            (),
            id="amd64_host_uses_plain_docker_build",
        ),
    ],
 )
 def test_local_build_targets_linux_amd64(
    deploy_project: DeployProject,
    monkeypatch: pytest.MonkeyPatch,
    machine: str,
    expected_command: tuple[str, ...],
    expected_flags: tuple[str, ...],
 ) -> None:
    monkeypatch.setattr(deploy_module.platform, "machine", lambda: machine)
    deploy_project.run("--no-remote")
    build = deploy_project.docker.builds[0]
    assert build["tag"].startswith("langgraph-deploy-tmp:")
    assert (build["docker_command"], build["extra_flags"]) == (
        expected_command,
        expected_flags,
    )
 def test_local_deploy_logs_in_with_the_control_plane_push_token(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.run("--no-remote")
    login = deploy_project.docker.command("login")
    assert login.args[:2] == ("docker", "--config")
    assert login.args[3:] == (
        "login",
        "-u",
        "oauth2accesstoken",
        "--password-stdin",
        "registry.example.com",
    )
    assert login.kwargs["input"] == f"{PUSH_TOKEN}\n"
 def test_local_deploy_tags_the_build_into_the_token_registry(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.run("--no-remote")
    built_tag = deploy_project.docker.builds[0]["tag"]
    assert deploy_project.docker.command("tag").args == (
        "docker",
        "tag",
        built_tag,
        PUSHED_IMAGE,
    )
    assert deploy_project.docker.command("push").args[-1] == PUSHED_IMAGE
 def test_local_deploy_records_the_pushed_digest_and_tracked_packages(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.run("--no-remote")
    assert deploy_project.control_plane.bodies[_patch(CREATED_ID)] == {
        "revision_source": "internal_docker",
        "source_revision_config": {"image_uri": PUSHED_DIGEST},
        "secrets": [],
        "tracked_packages": TRACKED_PACKAGES,
    }
 def test_status_link_points_at_the_langsmith_dashboard(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run("--no-remote")
    assert (
        "View status: https://smith.langchain.com/o/tenant-1/host/deployments/dep-created"
        in result.output
    )
 def test_prebuilt_image_is_validated_and_pushed_without_a_build(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run("--image", "local/app:dev")
    assert result.exit_code == 0, result.output
    assert deploy_project.docker.builds == []
    assert deploy_project.docker.verbs() == [
        "docker inspect-platform",
        "docker login",
        "docker tag",
        "docker push",
        "docker inspect-digest",
    ]
    assert deploy_project.docker.command("tag").args[2:] == (
        "local/app:dev",
        PUSHED_IMAGE,
    )
 def test_push_is_retried_until_the_third_attempt(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.docker.failing_pushes = 2
    result = deploy_project.run("--no-remote")
    assert result.exit_code == 0, result.output
    assert deploy_project.docker.verbs().count("docker push") == 3
 def test_three_failed_pushes_abort_before_the_deployment_is_updated(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.docker.failing_pushes = 3
    result = deploy_project.run("--no-remote")
    assert result.exit_code != 0
    assert _patch(CREATED_ID) not in deploy_project.timeline
 def test_existing_deployment_matched_by_exact_name_is_updated_not_created(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.control_plane.existing_deployments = [
        {"id": "dep-other", "name": "my-app-2"},
        {"id": "dep-existing", "name": "my-app"},
    ]
    deploy_project.run("--no-remote")
    assert CREATE_DEPLOYMENT not in deploy_project.timeline
    assert _patch("dep-existing") in deploy_project.timeline
 def test_deployment_not_created_by_the_cli_gets_an_actionable_error(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.control_plane.existing_deployments = [
        {"id": "dep-ui", "name": "my-app"}
    ]
    deploy_project.control_plane.push_token_status = 400
    result = deploy_project.run("--no-remote")
    assert result.exit_code != 0
    assert "was not created by 'langgraph deploy'" in result.output
    assert "docker login" not in deploy_project.timeline
 def test_remote_build_creates_an_internal_source_deployment_and_uploads_the_archive(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run("--remote", "--install-command", "yarn install")
    assert result.exit_code == 0, result.output
    assert deploy_project.timeline == [
        LIST_DEPLOYMENTS,
        CREATE_DEPLOYMENT,
        "create_archive",
        _upload_url(CREATED_ID),
        "upload_archive",
        _patch(CREATED_ID),
    ]
    assert deploy_project.control_plane.bodies[CREATE_DEPLOYMENT]["source"] == (
        "internal_source"
    )
    assert deploy_project.uploads == [(SIGNED_UPLOAD_URL, ARCHIVE[0], ARCHIVE[1])]
    assert deploy_project.control_plane.bodies[_patch(CREATED_ID)] == {
        "revision_source": "internal_source",
        "source_revision_config": {
            "source_tarball_path": OBJECT_PATH,
            "langgraph_config_path": ARCHIVE[2],
        },
        "source_config": {"install_command": "yarn install"},
        "secrets": [],
        "tracked_packages": TRACKED_PACKAGES,
    }
    assert "Build triggered" in result.output
 def test_push_to_builds_pushes_then_creates_an_external_deployment(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run("--push-to", PUSH_REPOSITORY)
    assert result.exit_code == 0, result.output
    assert deploy_project.timeline == [
        LIST_DEPLOYMENTS,
        "docker build",
        "docker push",
        "docker inspect-digest",
        CREATE_DEPLOYMENT,
    ]
    assert deploy_project.control_plane.bodies[CREATE_DEPLOYMENT] == {
        "name": "my-app",
        "source": "external_docker",
        "source_config": {"resource_spec": {}},
        "source_revision_config": {"image_uri": EXTERNAL_DIGEST},
        "secrets": [],
    }
    assert "Deployment created" in result.output
 def test_push_to_builds_directly_with_the_push_reference(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run("--push-to", PUSH_REPOSITORY)
    assert result.exit_code == 0, result.output
    assert deploy_project.docker.builds[0]["tag"] == EXTERNAL_IMAGE
    assert deploy_project.docker.command("push").args == (
        "docker",
        "push",
        EXTERNAL_IMAGE,
    )
 def test_push_to_composes_with_the_tag_flag(deploy_project: DeployProject) -> None:
    result = deploy_project.run("--push-to", PUSH_REPOSITORY, "--tag", "v1")
    assert result.exit_code == 0, result.output
    assert deploy_project.docker.command("push").args[-1] == f"{PUSH_REPOSITORY}:v1"
 def test_push_to_with_a_failing_push_creates_no_deployment(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.docker.failing_pushes = 3
    result = deploy_project.run("--push-to", PUSH_REPOSITORY)
    assert result.exit_code != 0
    assert CREATE_DEPLOYMENT not in deploy_project.timeline
 def test_verbose_never_echoes_the_push_token(deploy_project: DeployProject) -> None:
    result = deploy_project.run("--no-remote", "--verbose")
    assert result.exit_code == 0, result.output
    assert deploy_project.docker.command("login").kwargs["verbose"] is False
 def test_push_to_retags_a_prebuilt_image_instead_of_building(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run(
        "--image", "local/app:dev", "--push-to", PUSH_REPOSITORY
    )
    assert result.exit_code == 0, result.output
    assert deploy_project.docker.builds == []
    assert deploy_project.docker.verbs() == [
        "docker inspect-platform",
        "docker tag",
        "docker push",
        "docker inspect-digest",
    ]
    assert deploy_project.docker.command("tag").args == (
        "docker",
        "tag",
        "local/app:dev",
        EXTERNAL_IMAGE,
    )
 def test_push_to_updates_an_existing_external_deployment_with_the_new_image(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.control_plane.existing_deployments = [
        {"id": "dep-ext", "name": "my-app", "source": "external_docker"}
    ]
    result = deploy_project.run("--push-to", PUSH_REPOSITORY)
    assert result.exit_code == 0, result.output
    assert deploy_project.timeline == [
        LIST_DEPLOYMENTS,
        "docker build",
        "docker push",
        "docker inspect-digest",
        _patch("dep-ext"),
    ]
    assert deploy_project.control_plane.bodies[_patch("dep-ext")] == {
        "source_revision_config": {"image_uri": EXTERNAL_DIGEST},
        "secrets": [],
        "tracked_packages": TRACKED_PACKAGES,
    }
 def test_push_to_rejects_a_non_external_deployment_before_any_docker_work(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.control_plane.existing_deployments = [
        {"id": "dep-cli", "name": "my-app", "source": "internal_docker"}
    ]
    result = deploy_project.run("--push-to", PUSH_REPOSITORY)
    assert result.exit_code != 0
    assert "cannot be updated with --push-to" in result.output
    assert deploy_project.docker.verbs() == []
 def test_push_to_explains_the_listener_requirement_of_hybrid_workspaces(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.control_plane.create_error = LISTENER_REQUIRED
    result = deploy_project.run("--push-to", PUSH_REPOSITORY)
    assert result.exit_code != 0
    assert "listener" in result.output
    assert "--deployment-id" in result.output
 def test_push_to_with_deployment_id_fetches_the_deployment_once(
    deploy_project: DeployProject,
 ) -> None:
    deploy_project.control_plane.existing_deployments = [
        {"id": "dep-ext", "name": "another-name", "source": "external_docker"}
    ]
    result = deploy_project.run(
        "--deployment-id", "dep-ext", "--push-to", PUSH_REPOSITORY
    )
    assert result.exit_code == 0, result.output
    assert deploy_project.timeline == [
        _get("dep-ext"),
        "docker build",
        "docker push",
        "docker inspect-digest",
        _patch("dep-ext"),
    ]
 def test_invalid_tag_fails_before_any_control_plane_call(
    deploy_project: DeployProject,
 ) -> None:
    result = deploy_project.run("--no-remote", "--tag", "not a tag")
    assert result.exit_code != 0
    assert "Image tag may only contain" in result.output
    assert deploy_project.timeline == []
@@ -12,5 +12,5 @@ def disable_analytics_env() -> None:
    if "LANGGRAPH_CLI_NO_ANALYTICS" in os.environ:
        print("⚠️ LANGGRAPH_CLI_NO_ANALYTICS is set. Overriding it for the test.")
-    with patch.dict(os.environ, {"LANGGRAPH_CLI_NO_ANALYTICS": "1"}):
+    with patch.dict(os.environ, {"LANGGRAPH_CLI_NO_ANALYTICS": "0"}):
        yield
@@ -1,105 +0,0 @@
 import json
 from unittest.mock import Mock
 import httpx
 import pytest
 from click.testing import CliRunner
 import langgraph_cli.deploy as deploy
 from langgraph_cli.cli import cli
 from langgraph_cli.host_backend import HostBackendClient
@pytest.fixture
 def deployment_api(monkeypatch, tmp_path):
    monkeypatch.chdir(tmp_path)
    monkeypatch.delenv("LANGSMITH_DEPLOYMENT_NAME", raising=False)
    monkeypatch.setattr(deploy, "_emitter", None)
    monkeypatch.setattr(deploy, "_no_input", False)
    (tmp_path / "langgraph.json").write_text(
        json.dumps({"dependencies": ["."], "graphs": {"agent": "./agent.py:graph"}})
    )
    (tmp_path / ".env").write_text("LANGSMITH_DEPLOYMENT_NAME=legacy\n")
    requests = []
    state = {"enabled": True, "resources": []}
    def handler(request):
        requests.append(request)
        assert request.url.path == "/v2/deployments"
        if request.method == "GET":
            if not state["enabled"] and (
                "agent_id" in request.url.params
                or "agent_environment" in request.url.params
            ):
                return httpx.Response(
                    400, text="Agent filters are not available for this tenant."
                )
            return httpx.Response(200, json={"resources": state["resources"]})
        assert request.method == "POST"
        return httpx.Response(200, json={"id": "runtime-id", "name": "server-name"})
    client = HostBackendClient("https://api.example.com", "test-key")
    client._client.close()
    client._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "test-key"},
    )
    monkeypatch.setattr(deploy, "_create_host_backend_client", lambda *a, **kw: client)
    monkeypatch.setattr(deploy, "find_tracked_packages", lambda *a: [])
    remote_build = Mock(return_value=deploy.BuildResult())
    monkeypatch.setattr(deploy, "_run_remote_build", remote_build)
    monkeypatch.setattr(deploy, "_resolve_build_mode", lambda flag, **kw: (flag, None))
    yield state, requests, remote_build
    client._client.close()
 AGENT_ARGS = [
    "deploy",
    "--agent-id",
    "customer-support",
    "--environment",
    "staging",
    "--remote",
    "--no-wait",
    "--no-input",
 ]
 def test_agent_create(deployment_api, tmp_path, monkeypatch):
    monkeypatch.setenv("LANGSMITH_DEPLOYMENT_NAME", "legacy")
    _, requests, build = deployment_api
    result = CliRunner().invoke(cli, AGENT_ARGS)
    assert result.exit_code == 0, result.output
    assert dict(requests[0].url.params) == {
        "name_contains": "",
        "agent_id": "customer-support",
        "agent_environment": "staging",
    }
    payload = json.loads(requests[1].content)
    assert payload["agent"] == {
        "agent_id": "customer-support",
        "environment": "staging",
    }
    assert "name" not in payload
    assert build.call_args.kwargs["deployment_id"] == "runtime-id"
    assert "server-name" in result.output
    assert (tmp_path / ".env").read_text() == "LANGSMITH_DEPLOYMENT_NAME=legacy\n"
 def test_agent_update(deployment_api):
    state, requests, build = deployment_api
    state["resources"] = [{"id": "existing-id", "is_preview": False}]
    result = CliRunner().invoke(cli, AGENT_ARGS)
    assert result.exit_code == 0, result.output
    assert len(requests) == 1
    assert build.call_args.kwargs["deployment_id"] == "existing-id"
 def test_agent_rejects_explicit_name(deployment_api, monkeypatch):
    monkeypatch.setenv("LANGSMITH_DEPLOYMENT_NAME", "legacy")
    _, requests, _ = deployment_api
    result = CliRunner().invoke(cli, [*AGENT_ARGS, "--name", "legacy"])
    assert result.exit_code == 2
    assert "cannot be combined" in result.output
    assert not requests
@@ -13,10 +13,6 @@ import pytest
 import langgraph_cli.deploy as deploy_mod
 from langgraph_cli.deploy import (
    CustomerRegistrySource,
    DockerBuildCommand,
    ManagedRegistrySource,
    RemoteBuildSource,
    _call_host_backend_with_optional_tenant,
    _create_host_backend_client,
    _docker_config_for_token,
@@ -25,13 +21,13 @@ from langgraph_cli.deploy import (
    _parse_env_from_config,
    _resolve_env_path,
    _resolve_pushed_image_digest,
-    _select_source,
+    _secrets_from_env,
    _smith_dashboard_base_url,
    _validate_prebuilt_image,
    normalize_image_tag,
    normalize_name,
 )
 from langgraph_cli.host_backend import HostBackendClient, HostBackendError
 from langgraph_cli.image_reference import ImageReference
 class TestDockerConfigForToken:
@@ -264,18 +260,22 @@ class TestEnvWithoutDeploymentName:
 class TestCallHostBackendWithOptionalTenant:
    def _make_client(self, handler):
-        c = HostBackendClient(
+        c = HostBackendClient("https://api.example.com", "test-key")
-            "https://api.example.com",
+        c._client = httpx.Client(
-            "test-key",
+            base_url="https://api.example.com",
            transport=httpx.MockTransport(handler),
            headers={"X-Api-Key": "test-key", "Accept": "application/json"},
            timeout=30,
        )
        return c
    def _make_eu_client(self, handler):
-        c = HostBackendClient(
+        c = HostBackendClient("https://eu.api.host.langchain.com", "test-key")
-            "https://eu.api.host.langchain.com",
+        c._client = httpx.Client(
-            "test-key",
+            base_url="https://eu.api.host.langchain.com",
            transport=httpx.MockTransport(handler),
            headers={"X-Api-Key": "test-key", "Accept": "application/json"},
            timeout=30,
        )
        return c
@@ -335,6 +335,7 @@ class TestCallHostBackendWithOptionalTenant:
        assert exc_info.value.status_code == 403
        assert "smith.langchain.com" in exc_info.value.message
        assert seen_tenant_ids == [None, "workspace-123"]
        assert client._client.headers["X-Tenant-ID"] == "workspace-123"
    def test_other_403_re_raises_original(self):
        client = self._make_client(
@@ -540,193 +541,117 @@ class TestCreateHostBackendClientNoInput:
        assert client is not None
-class TestCreateHostBackendClientEndpoint:
+@pytest.mark.parametrize("source", ["config", "shell"])
-    def test_langsmith_endpoint_from_project_env_selects_self_hosted_control_plane(
+@pytest.mark.parametrize("name", ["LANGSMITH_TENANT_ID", "LANGSMITH_WORKSPACE_ID"])
-        self, monkeypatch
+def test_workspace_id_alias(monkeypatch, source, name):
    monkeypatch.delenv("LANGSMITH_WORKSPACE_ID", raising=False)
    monkeypatch.delenv("LANGSMITH_TENANT_ID", raising=False)
    env_vars = {}
    if source == "config":
        env_vars[name] = "workspace"
    else:
        monkeypatch.setenv(name, "workspace")
    def handler(request):
        assert request.headers["X-Tenant-ID"] == "workspace"
        return httpx.Response(200, json={"resources": []})
    monkeypatch.setattr(
        httpx, "HTTPTransport", lambda **kwargs: httpx.MockTransport(handler)
    )
    client = _create_host_backend_client(
        "https://api.example.com", "test-key", env_vars
    )
    try:
        client.list_deployments()
    finally:
        client._client.close()
@pytest.mark.parametrize("tenant_source", ["config", "shell"])
@pytest.mark.parametrize("workspace_source", ["config", "shell"])
@pytest.mark.parametrize("workspace_id", ["tenant-id", "workspace-id"])
 def test_rejects_both_workspace_names(
    monkeypatch, tenant_source, workspace_source, workspace_id
 ):
    env_vars = {}
    for name, source, value in [
        ("LANGSMITH_TENANT_ID", tenant_source, "tenant-id"),
        ("LANGSMITH_WORKSPACE_ID", workspace_source, workspace_id),
    ]:
        monkeypatch.delenv(name, raising=False)
        if source == "config":
            env_vars[name] = value
        else:
            monkeypatch.setenv(name, value)
    with pytest.raises(
        click.UsageError,
        match="LANGSMITH_TENANT_ID and LANGSMITH_WORKSPACE_ID cannot both be set",
    ):
-        monkeypatch.setenv("LANGSMITH_API_KEY", "lsv2_test")
+        _create_host_backend_client("https://api.example.com", "test-key", env_vars)
        monkeypatch.delenv("LANGSMITH_ENDPOINT", raising=False)
-        client = _create_host_backend_client(
+
-            host_url=None,
+def test_workspace_id_is_not_uploaded_as_secret():
-            api_key=None,
+    assert _secrets_from_env(
-            env_vars={"LANGSMITH_ENDPOINT": "https://smith.example.com/api/v1"},
+        {"LANGSMITH_WORKSPACE_ID": "workspace", "APP_SETTING": "value"}
    ) == [{"name": "APP_SETTING", "value": "value"}]
 class TestSmithDashboardBaseUrl:
    def test_none_returns_default(self):
        assert _smith_dashboard_base_url(None) == "https://smith.langchain.com"
    def test_empty_returns_default(self):
        assert _smith_dashboard_base_url("") == "https://smith.langchain.com"
    def test_prod_host_url(self):
        assert (
            _smith_dashboard_base_url("https://api.host.langchain.com")
            == "https://smith.langchain.com"
        )
-        assert client.base_url == "https://smith.example.com/api-host"
+    def test_dev_host_url(self):
-
+        assert (
-    def test_explicit_host_url_wins_over_langsmith_endpoint(self, monkeypatch):
+            _smith_dashboard_base_url("https://dev.api.host.langchain.com")
-        monkeypatch.setenv("LANGSMITH_API_KEY", "lsv2_test")
+            == "https://dev.smith.langchain.com"
        monkeypatch.setenv("LANGSMITH_ENDPOINT", "https://smith.example.com/api/v1")
        client = _create_host_backend_client(
            host_url="https://custom.host.com", api_key=None, env_vars={}
        )
-        assert client.base_url == "https://custom.host.com"
+    def test_eu_host_url(self):
-
+        assert (
-
+            _smith_dashboard_base_url("https://eu.api.host.langchain.com")
-class TestDockerBuildCommand:
+            == "https://eu.smith.langchain.com"
    @pytest.mark.parametrize(
        ("machine", "verbose", "expected"),
        [
            pytest.param(
                "x86_64",
                False,
                DockerBuildCommand(("docker", "build"), ()),
                id="amd64_host_builds_natively",
            ),
            pytest.param(
                "arm64",
                False,
                DockerBuildCommand(
                    ("docker", "buildx", "build"),
                    ("--platform", "linux/amd64", "--load", "--progress=quiet"),
                ),
                id="other_hosts_cross_build_quietly",
            ),
            pytest.param(
                "arm64",
                True,
                DockerBuildCommand(
                    ("docker", "buildx", "build"),
                    ("--platform", "linux/amd64", "--load"),
                ),
                id="verbose_cross_build_keeps_progress_output",
            ),
        ],
    )
    def test_for_host_targets_the_deployment_platform(self, machine, verbose, expected):
        assert DockerBuildCommand.for_host(machine, verbose=verbose) == expected
 class TestSelectSource:
    OPTIONS = {
        "push_to": None,
        "image": None,
        "image_name": None,
        "tag": None,
        "remote_build_flag": None,
    }
    REPOSITORY = "registry.example.com/app"
    @pytest.mark.parametrize(
        ("flags", "docker_available", "expected"),
        [
            pytest.param(
                {"push_to": REPOSITORY},
                True,
                CustomerRegistrySource(
                    ImageReference(REPOSITORY, "latest"), prebuilt_image=None
                ),
                id="push_to_selects_the_external_source_with_the_default_tag",
            ),
            pytest.param(
                {"push_to": f"{REPOSITORY}:v2"},
                True,
                CustomerRegistrySource(
                    ImageReference(REPOSITORY, "v2"), prebuilt_image=None
                ),
                id="push_to_keeps_a_tag_given_in_the_reference",
            ),
            pytest.param(
                {"push_to": REPOSITORY, "tag": "v3"},
                True,
                CustomerRegistrySource(
                    ImageReference(REPOSITORY, "v3"), prebuilt_image=None
                ),
                id="tag_flag_composes_with_push_to",
            ),
            pytest.param(
                {"push_to": REPOSITORY, "image": "app:dev"},
                False,
                CustomerRegistrySource(
                    ImageReference(REPOSITORY, "latest"), prebuilt_image="app:dev"
                ),
                id="prebuilt_image_is_retagged_for_push_to_without_docker_checks",
            ),
            pytest.param(
                {"remote_build_flag": True},
                True,
                RemoteBuildSource(),
                id="remote_flag_selects_the_source_upload",
            ),
            pytest.param(
                {},
                False,
                RemoteBuildSource(),
                id="no_local_docker_falls_back_to_the_source_upload",
            ),
            pytest.param(
                {},
                True,
                ManagedRegistrySource(
                    prebuilt_image=None, image_name=None, tag="latest"
                ),
                id="local_docker_selects_the_internal_docker_source",
            ),
            pytest.param(
                {"image": "app:dev", "tag": "v1"},
                False,
                ManagedRegistrySource(
                    prebuilt_image="app:dev", image_name=None, tag="v1"
                ),
                id="prebuilt_image_forces_the_internal_docker_source",
            ),
        ],
    )
    def test_flags_select_one_source(
        self, monkeypatch, mocker, flags, docker_available, expected
    ):
        mocker.patch(
            "langgraph_cli.deploy._get_emitter", return_value=mocker.MagicMock()
        )
        monkeypatch.setattr(
            deploy_mod,
            "can_build_locally",
            lambda: (True, None) if docker_available else (False, "Docker is required"),
        )
-        assert _select_source(**{**self.OPTIONS, **flags}) == expected
+    def test_staging_host_url(self):
-
+        assert (
-    def test_push_to_build_requires_local_docker(self, monkeypatch):
+            _smith_dashboard_base_url("https://staging.api.host.langchain.com")
-        monkeypatch.setattr(
+            == "https://staging.smith.langchain.com"
            deploy_mod, "can_build_locally", lambda: (False, "Docker is required")
        )
-        with pytest.raises(click.UsageError, match="Docker is required"):
+    def test_localhost(self):
-            _select_source(**{**self.OPTIONS, "push_to": self.REPOSITORY})
+        assert (
            _smith_dashboard_base_url("http://localhost:8080")
            == "http://localhost:8080"
        )
-    @pytest.mark.parametrize(
+    def test_localhost_trailing_slash(self):
-        ("flags", "message"),
+        assert (
-        [
+            _smith_dashboard_base_url("http://localhost:8080/")
-            pytest.param(
+            == "http://localhost:8080"
-                {"push_to": REPOSITORY, "remote_build_flag": True},
+        )
                "--push-to cannot be combined with --remote.",
                id="push_to_with_remote",
            ),
            pytest.param(
                {"push_to": f"{REPOSITORY}:v1", "tag": "v2"},
                "already includes a tag",
                id="push_to_with_a_tag_and_the_tag_flag",
            ),
            pytest.param(
                {"push_to": f"{REPOSITORY}@sha256:abc"},
                "not a digest",
                id="push_to_with_a_digest",
            ),
            pytest.param(
                {"image": "app:dev", "remote_build_flag": True},
                "--image cannot be combined with --remote builds.",
                id="image_with_remote",
            ),
        ],
    )
    def test_conflicting_flags_are_rejected(self, monkeypatch, flags, message):
        monkeypatch.setattr(deploy_mod, "can_build_locally", lambda: (True, None))
-        with pytest.raises(click.UsageError, match=message):
+    def test_127_0_0_1(self):
-            _select_source(**{**self.OPTIONS, **flags})
+        assert (
            _smith_dashboard_base_url("http://127.0.0.1:3000")
            == "http://127.0.0.1:3000"
        )
    def test_unknown_domain_returns_default(self):
        assert (
            _smith_dashboard_base_url("https://custom.example.com")
            == "https://smith.langchain.com"
        )
 class TestResolvePushedImageDigest:
@@ -777,16 +702,6 @@ class TestResolvePushedImageDigest:
        )
        assert out == "us-central1-docker.pkg.dev/proj/repo@sha256:abc123"
    def test_registry_port_without_tag_still_resolves_the_digest(self):
        runner = self._runner('["localhost:5000/repo@sha256:abc123"]')
        out = _resolve_pushed_image_digest(
            runner,
            remote_image="localhost:5000/repo",
            docker_config_dir=None,
            verbose=False,
        )
        assert out == "localhost:5000/repo@sha256:abc123"
    def test_empty_repodigests_falls_back_with_warning(self, mocker):
        emitter = mocker.MagicMock()
        mocker.patch("langgraph_cli.deploy._get_emitter", return_value=emitter)
@@ -3,16 +3,29 @@ import json
 import httpx
 import pytest
-from langgraph_cli.host_backend import (
+from langgraph_cli.host_backend import HostBackendClient, HostBackendError
-    ControlPlaneEndpoints,
+
-    HostBackendClient,
+
-    HostBackendError,
+@pytest.fixture
-)
+def mock_transport():
    return httpx.MockTransport(lambda req: httpx.Response(200, json={"ok": True}))
@pytest.fixture
 def client(mock_transport):
    c = HostBackendClient("https://api.example.com", "test-key")
    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=mock_transport,
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    return c
 def test_constructor_strips_trailing_slash():
    c = HostBackendClient("https://api.example.com/", "key")
-    assert c.base_url == "https://api.example.com"
+    assert str(c._client.base_url) == "https://api.example.com"
 def test_constructor_empty_url_raises():
@@ -26,8 +39,12 @@ def test_request_sends_headers():
        assert req.headers["accept"] == "application/json"
        return httpx.Response(200, json={"ok": True})
-    c = HostBackendClient(
+    c = HostBackendClient("https://api.example.com", "test-key")
-        "https://api.example.com", "test-key", transport=httpx.MockTransport(handler)
+    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    result = c._request("GET", "/test")
    assert result == {"ok": True}
@@ -39,8 +56,12 @@ def test_request_sends_json_payload():
        assert req.content == b'{"key":"value"}'
        return httpx.Response(200, json={"created": True})
-    c = HostBackendClient(
+    c = HostBackendClient("https://api.example.com", "test-key")
-        "https://api.example.com", "test-key", transport=httpx.MockTransport(handler)
+    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    result = c._request("POST", "/test", {"key": "value"})
    assert result == {"created": True}
@@ -48,13 +69,25 @@ def test_request_sends_json_payload():
 def test_request_empty_body_returns_none():
    transport = httpx.MockTransport(lambda req: httpx.Response(200, content=b""))
-    c = HostBackendClient("https://api.example.com", "test-key", transport=transport)
+    c = HostBackendClient("https://api.example.com", "test-key")
    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=transport,
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    assert c._request("DELETE", "/test") is None
 def test_request_http_error_raises():
    transport = httpx.MockTransport(lambda req: httpx.Response(404, text="not found"))
-    c = HostBackendClient("https://api.example.com", "test-key", transport=transport)
+    c = HostBackendClient("https://api.example.com", "test-key")
    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=transport,
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    with pytest.raises(HostBackendError, match="404"):
        c._request("GET", "/missing")
@@ -63,7 +96,13 @@ def test_request_invalid_json_raises():
    transport = httpx.MockTransport(
        lambda req: httpx.Response(200, content=b"not json")
    )
-    c = HostBackendClient("https://api.example.com", "test-key", transport=transport)
+    c = HostBackendClient("https://api.example.com", "test-key")
    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=transport,
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    with pytest.raises(HostBackendError, match="Failed to decode"):
        c._request("GET", "/bad-json")
@@ -72,33 +111,84 @@ def test_request_transport_error_raises():
    def handler(req: httpx.Request) -> httpx.Response:
        raise httpx.ConnectError("connection refused")
-    c = HostBackendClient(
+    c = HostBackendClient("https://api.example.com", "test-key")
-        "https://api.example.com", "test-key", transport=httpx.MockTransport(handler)
+    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    with pytest.raises(HostBackendError, match="connection refused"):
        c._request("GET", "/test")
 def test_create_deployment(client):
    result = client.create_deployment(
        name="my-deploy", deployment_type="dev", source="internal_docker"
    )
    assert result == {"ok": True}
 def test_get_deployment(client):
    result = client.get_deployment("dep-123")
    assert result == {"ok": True}
 def test_list_deployments(client):
    result = client.list_deployments("my-app")
    assert result == {"ok": True}
 def test_list_deployments_sends_query_params():
    def handler(req: httpx.Request) -> httpx.Response:
        assert req.url.path == "/v2/deployments"
        assert req.url.params["name_contains"] == "my app"
        return httpx.Response(200, json={"ok": True})
-    c = HostBackendClient(
+    c = HostBackendClient("https://api.example.com", "test-key")
-        "https://api.example.com", "test-key", transport=httpx.MockTransport(handler)
+    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "test-key", "Accept": "application/json"},
        timeout=30,
    )
    result = c.list_deployments("my app")
    assert result == {"ok": True}
 def test_delete_deployment(client):
    result = client.delete_deployment("dep-123")
    assert result == {"ok": True}
 def test_request_push_token(client):
    result = client.request_push_token("dep-123")
    assert result == {"ok": True}
 def test_update_deployment(client):
    result = client.update_deployment(
        "dep-123", "image:latest", secrets=[{"name": "KEY", "value": "val"}]
    )
    assert result == {"ok": True}
 def test_update_deployment_no_secrets(client):
    result = client.update_deployment("dep-123", "image:latest")
    assert result == {"ok": True}
 def _capturing_client(captured: dict) -> HostBackendClient:
    def handler(req: httpx.Request) -> httpx.Response:
        captured["body"] = req.read()
        return httpx.Response(200, json={"ok": True})
-    c = HostBackendClient(
+    c = HostBackendClient("https://api.example.com", "key")
-        "https://api.example.com", "key", transport=httpx.MockTransport(handler)
+    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "key", "Accept": "application/json"},
        timeout=30,
    )
    return c
@@ -109,7 +199,6 @@ def test_update_deployment_forwards_tracked_packages():
    c.update_deployment(
        "dep-123",
        "image:latest",
        revision_source="internal_docker",
        tracked_packages=["google-adk:1.0.0"],
    )
    body = json.loads(captured["body"])
@@ -120,7 +209,7 @@ def test_update_deployment_forwards_tracked_packages():
 def test_update_deployment_omits_tracked_packages_when_absent():
    captured: dict = {}
    c = _capturing_client(captured)
-    c.update_deployment("dep-123", "image:latest", revision_source="internal_docker")
+    c.update_deployment("dep-123", "image:latest")
    body = json.loads(captured["body"])
    assert "tracked_packages" not in body
@@ -152,14 +241,33 @@ def test_update_deployment_internal_source_omits_tracked_packages_when_absent():
    assert "tracked_packages" not in body
 def test_list_revisions(client):
    result = client.list_revisions("dep-123", limit=5)
    assert result == {"ok": True}
 def test_get_revision(client):
    result = client.get_revision("dep-123", "rev-456")
    assert result == {"ok": True}
 def test_get_build_logs(client):
    result = client.get_build_logs("proj-1", "rev-1", {"limit": 10})
    assert result == {"ok": True}
 def test_get_deploy_logs_all_revisions():
    def handler(req: httpx.Request) -> httpx.Response:
        assert "/v1/projects/proj-1/deploy_logs" in str(req.url)
        assert "/revisions/" not in str(req.url)
        return httpx.Response(200, json={"logs": [{"message": "running"}]})
-    c = HostBackendClient(
+    c = HostBackendClient("https://api.example.com", "key")
-        "https://api.example.com", "key", transport=httpx.MockTransport(handler)
+    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "key", "Accept": "application/json"},
        timeout=30,
    )
    result = c.get_deploy_logs("proj-1", {"limit": 10})
    assert result == {"logs": [{"message": "running"}]}
@@ -170,379 +278,12 @@ def test_get_deploy_logs_specific_revision():
        assert "/v1/projects/proj-1/revisions/rev-2/deploy_logs" in str(req.url)
        return httpx.Response(200, json={"logs": []})
-    c = HostBackendClient(
+    c = HostBackendClient("https://api.example.com", "key")
-        "https://api.example.com", "key", transport=httpx.MockTransport(handler)
+    c._client = httpx.Client(
        base_url="https://api.example.com",
        transport=httpx.MockTransport(handler),
        headers={"X-Api-Key": "key", "Accept": "application/json"},
        timeout=30,
    )
    result = c.get_deploy_logs("proj-1", {"limit": 10}, revision_id="rev-2")
    assert result == {"logs": []}
 def _routing_client(seen: dict) -> HostBackendClient:
    def handler(req: httpx.Request) -> httpx.Response:
        seen["method"] = req.method
        seen["url"] = str(req.url)
        return httpx.Response(200, json={"ok": True})
    c = HostBackendClient(
        "https://api.example.com/prefix", "key", transport=httpx.MockTransport(handler)
    )
    return c
@pytest.mark.parametrize(
    ("call", "expected_body"),
    [
        pytest.param(
            lambda c: c.create_deployment(
                name="my-deploy",
                source="internal_docker",
                source_config={"deployment_type": "dev"},
                source_revision_config={},
            ),
            {
                "name": "my-deploy",
                "source": "internal_docker",
                "source_config": {"deployment_type": "dev"},
                "source_revision_config": {},
            },
            id="internal_docker_create_omits_secrets_key_when_not_given",
        ),
        pytest.param(
            lambda c: c.create_deployment(
                name="my-deploy",
                source="internal_docker",
                source_config={"deployment_type": "prod"},
                source_revision_config={},
                secrets=[{"name": "KEY", "value": "val"}],
            ),
            {
                "name": "my-deploy",
                "source": "internal_docker",
                "source_config": {"deployment_type": "prod"},
                "source_revision_config": {},
                "secrets": [{"name": "KEY", "value": "val"}],
            },
            id="internal_docker_create_forwards_secrets",
        ),
        pytest.param(
            lambda c: c.update_deployment(
                "dep-123",
                "registry.example.com/app@sha256:abc",
                revision_source="internal_docker",
                secrets=[{"name": "KEY", "value": "val"}],
            ),
            {
                "revision_source": "internal_docker",
                "source_revision_config": {
                    "image_uri": "registry.example.com/app@sha256:abc"
                },
                "secrets": [{"name": "KEY", "value": "val"}],
            },
            id="internal_docker_revision_names_its_source",
        ),
        pytest.param(
            lambda c: c.update_deployment_internal_source(
                "dep-123",
                source_tarball_path="tarballs/src.tgz",
                config_path="langgraph.json",
                secrets=[],
                install_command="yarn install",
                build_command="yarn build",
            ),
            {
                "revision_source": "internal_source",
                "source_revision_config": {
                    "source_tarball_path": "tarballs/src.tgz",
                    "langgraph_config_path": "langgraph.json",
                },
                "source_config": {
                    "install_command": "yarn install",
                    "build_command": "yarn build",
                },
                "secrets": [],
            },
            id="internal_source_revision_sends_js_build_commands",
        ),
        pytest.param(
            lambda c: c.update_deployment_internal_source(
                "dep-123",
                source_tarball_path="tarballs/src.tgz",
                config_path="langgraph.json",
            ),
            {
                "revision_source": "internal_source",
                "source_revision_config": {
                    "source_tarball_path": "tarballs/src.tgz",
                    "langgraph_config_path": "langgraph.json",
                },
            },
            id="internal_source_revision_omits_source_config_without_commands",
        ),
        pytest.param(
            lambda c: c.create_deployment(
                name="agent",
                source="external_docker",
                source_config={"resource_spec": {}},
                source_revision_config={
                    "image_uri": "registry.example.com/agent@sha256:1"
                },
                secrets=[],
            ),
            {
                "name": "agent",
                "source": "external_docker",
                "source_config": {"resource_spec": {}},
                "source_revision_config": {
                    "image_uri": "registry.example.com/agent@sha256:1"
                },
                "secrets": [],
            },
            id="create_sends_the_source_configs_as_given",
        ),
        pytest.param(
            lambda c: c.update_deployment(
                "dep-1", "registry.example.com/agent@sha256:2", revision_source=None
            ),
            {
                "source_revision_config": {
                    "image_uri": "registry.example.com/agent@sha256:2"
                }
            },
            id="revision_without_source_override_omits_revision_source",
        ),
        pytest.param(
            lambda c: c.update_deployment(
                "dep-1",
                "registry.example.com/agent@sha256:2",
                revision_source="internal_docker",
                tracked_packages=["langgraph:1.0.0"],
            ),
            {
                "revision_source": "internal_docker",
                "source_revision_config": {
                    "image_uri": "registry.example.com/agent@sha256:2"
                },
                "tracked_packages": ["langgraph:1.0.0"],
            },
            id="revision_with_source_override_names_it",
        ),
    ],
 )
 def test_request_body_matches_control_plane_contract(call, expected_body):
    captured: dict = {}
    call(_capturing_client(captured))
    assert json.loads(captured["body"]) == expected_body
@pytest.mark.parametrize(
    ("call", "method", "route"),
    [
        pytest.param(
            lambda c: c.create_deployment(
                name="n",
                source="internal_docker",
                source_config={"deployment_type": "dev"},
                source_revision_config={},
            ),
            "POST",
            "/v2/deployments",
            id="create_deployment",
        ),
        pytest.param(
            lambda c: c.get_deployment("dep-1"),
            "GET",
            "/v2/deployments/dep-1",
            id="get_deployment",
        ),
        pytest.param(
            lambda c: c.delete_deployment("dep-1"),
            "DELETE",
            "/v2/deployments/dep-1",
            id="delete_deployment",
        ),
        pytest.param(
            lambda c: c.update_deployment("dep-1", "img", revision_source=None),
            "PATCH",
            "/v2/deployments/dep-1",
            id="patch_deployment",
        ),
        pytest.param(
            lambda c: c.request_push_token("dep-1"),
            "POST",
            "/v2/deployments/dep-1/push-token",
            id="push_token",
        ),
        pytest.param(
            lambda c: c.request_upload_url("dep-1"),
            "POST",
            "/v2/deployments/dep-1/upload-url",
            id="upload_url",
        ),
        pytest.param(
            lambda c: c.list_revisions("dep-1", limit=5),
            "GET",
            "/v2/deployments/dep-1/revisions?limit=5",
            id="list_revisions_puts_limit_in_query",
        ),
        pytest.param(
            lambda c: c.get_revision("dep-1", "rev-2"),
            "GET",
            "/v2/deployments/dep-1/revisions/rev-2",
            id="get_revision",
        ),
        pytest.param(
            lambda c: c.get_build_logs("dep-1", "rev-2", {"limit": 10}),
            "POST",
            "/v1/projects/dep-1/revisions/rev-2/build_logs",
            id="build_logs",
        ),
    ],
 )
 def test_request_targets_control_plane_route_under_base_url(call, method, route):
    seen: dict = {}
    call(_routing_client(seen))
    assert (seen["method"], seen["url"]) == (
        method,
        f"https://api.example.com/prefix{route}",
    )
 def test_injected_transport_receives_requests_under_the_prefixed_base_url():
    seen: dict = {}
    def handler(req: httpx.Request) -> httpx.Response:
        seen["url"] = str(req.url)
        seen["api_key"] = req.headers["x-api-key"]
        return httpx.Response(200, json={"ok": True})
    c = HostBackendClient(
        "https://smith.example.com/api-host",
        "key",
        transport=httpx.MockTransport(handler),
    )
    assert c.list_revisions("dep-1", limit=2) == {"ok": True}
    assert seen == {
        "url": "https://smith.example.com/api-host/v2/deployments/dep-1/revisions?limit=2",
        "api_key": "key",
    }
 CLOUD = ("https://api.host.langchain.com", "https://smith.langchain.com")
@pytest.mark.parametrize(
    ("host_url", "langsmith_endpoint", "expected"),
    [
        pytest.param(None, None, CLOUD, id="nothing_configured_targets_cloud"),
        pytest.param(
            None, "https://api.smith.langchain.com", CLOUD, id="cloud_langsmith_api"
        ),
        pytest.param(
            None,
            "https://api.smith.langchain.com/api/v1",
            CLOUD,
            id="cloud_langsmith_api_with_versioned_path",
        ),
        pytest.param(
            None, "https://api.langchain.com", CLOUD, id="cloud_langchain_api_alias"
        ),
        pytest.param(
            None,
            "https://xapi.smith.langchain.com",
            CLOUD,
            id="lookalike_cloud_host_is_not_rewritten_into_a_control_plane",
        ),
        pytest.param(
            None,
            "https://eu.api.smith.langchain.com",
            ("https://eu.api.host.langchain.com", "https://eu.smith.langchain.com"),
            id="eu_cloud_maps_to_eu_control_plane",
        ),
        pytest.param(
            None,
            "https://dev.api.smith.langchain.com",
            ("https://dev.api.host.langchain.com", "https://dev.smith.langchain.com"),
            id="dev_cloud_maps_to_dev_control_plane",
        ),
        pytest.param(
            None,
            "https://aks.smith.langchain.dev/api",
            (
                "https://aks.smith.langchain.dev/api-host",
                "https://aks.smith.langchain.dev",
            ),
            id="self_hosted_api_path_becomes_api_host",
        ),
        pytest.param(
            None,
            "https://smith.example.com/api/v1",
            ("https://smith.example.com/api-host", "https://smith.example.com"),
            id="self_hosted_versioned_api_path_becomes_api_host",
        ),
        pytest.param(
            None,
            "https://smith.example.com",
            ("https://smith.example.com/api-host", "https://smith.example.com"),
            id="self_hosted_origin_gets_api_host_appended",
        ),
        pytest.param(
            None,
            "https://corp.example.com/langsmith/api/v1",
            (
                "https://corp.example.com/langsmith/api-host",
                "https://corp.example.com/langsmith",
            ),
            id="self_hosted_path_prefix_is_kept",
        ),
        pytest.param(
            "https://custom.host.example",
            "https://aks.smith.langchain.dev/api",
            ("https://custom.host.example", "https://smith.langchain.com"),
            id="explicit_host_url_beats_langsmith_endpoint",
        ),
        pytest.param(
            "https://api.host.langchain.com",
            "https://aks.smith.langchain.dev/api",
            CLOUD,
            id="explicit_cloud_host_url_beats_self_hosted_endpoint",
        ),
        pytest.param(
            "https://smith.example.com/api-host/",
            None,
            ("https://smith.example.com/api-host", "https://smith.example.com"),
            id="explicit_api_host_url_derives_dashboard_root",
        ),
        pytest.param(
            "https://corp.example.com/langsmith/api-host",
            None,
            (
                "https://corp.example.com/langsmith/api-host",
                "https://corp.example.com/langsmith",
            ),
            id="explicit_api_host_url_keeps_path_prefix_in_dashboard",
        ),
        pytest.param(
            "http://localhost:8080",
            None,
            ("http://localhost:8080", "http://localhost:8080"),
            id="localhost_dashboard_is_the_same_origin",
        ),
        pytest.param(
            "http://localhost:8080/api-host",
            None,
            ("http://localhost:8080/api-host", "http://localhost:8080"),
            id="localhost_api_host_dashboard_is_the_origin",
        ),
        pytest.param(
            "https://eu.api.host.langchain.com",
            None,
            ("https://eu.api.host.langchain.com", "https://eu.smith.langchain.com"),
            id="regional_control_plane_maps_to_regional_dashboard",
        ),
    ],
 )
 def test_control_plane_endpoints_resolve(host_url, langsmith_endpoint, expected):
    endpoints = ControlPlaneEndpoints.resolve(host_url, langsmith_endpoint)
    assert (endpoints.control_plane_url, endpoints.dashboard_url) == expected
@@ -1,71 +0,0 @@
 import pytest
 from langgraph_cli.image_reference import ImageReference
@pytest.mark.parametrize(
    ("reference", "repository", "tag"),
    [
        pytest.param(
            "registry.example.com/team/app:v1",
            "registry.example.com/team/app",
            "v1",
            id="tag_after_last_slash",
        ),
        pytest.param(
            "registry.example.com/team/app",
            "registry.example.com/team/app",
            None,
            id="no_tag",
        ),
        pytest.param(
            "localhost:5000/app",
            "localhost:5000/app",
            None,
            id="registry_port_is_not_a_tag",
        ),
        pytest.param(
            "localhost:5000/app:latest",
            "localhost:5000/app",
            "latest",
            id="registry_port_with_tag",
        ),
        pytest.param("app:dev", "app", "dev", id="bare_name_with_tag"),
    ],
 )
 def test_parse_splits_repository_and_tag(reference, repository, tag):
    assert ImageReference.parse(reference) == ImageReference(repository, tag)
 def test_with_tag_replaces_the_tag():
    assert ImageReference("r/app", "v1").with_tag("v2") == ImageReference("r/app", "v2")
@pytest.mark.parametrize(
    ("reference", "expected"),
    [
        pytest.param(ImageReference("r/app", "v1"), "r/app:v1", id="tagged"),
        pytest.param(ImageReference("r/app"), "r/app", id="untagged"),
    ],
 )
 def test_str_renders_the_docker_reference(reference, expected):
    assert str(reference) == expected
@pytest.mark.parametrize(
    ("repo_digest", "expected"),
    [
        pytest.param("localhost:5000/app@sha256:abc", True, id="same_repository"),
        pytest.param("localhost:5000/app-2@sha256:abc", False, id="other_repository"),
        pytest.param("mirror.example.com/app@sha256:abc", False, id="other_registry"),
    ],
 )
 def test_matches_digest_only_for_the_same_repository(repo_digest, expected):
    assert ImageReference("localhost:5000/app", "v1").matches_digest(repo_digest) is (
        expected
    )
 def test_parse_rejects_a_digest_reference():
    with pytest.raises(ValueError, match="digest"):
        ImageReference.parse("registry.example.com/app@sha256:abc")
@@ -39,15 +39,15 @@ wheels = [
 [[package]]
 name = "anyio"
-version = "4.14.2"
+version = "4.13.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "idna" },
    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/61/cc/a381afa6efea9f496eff839d4a6a1aed3bfafc7b3ab4b0d1b243a12573dd/anyio-4.14.2.tar.gz", hash = "sha256:cfa139f3ed1a23ee8f88a145ddb5ac7605b8bbfd8592baacd7ce3d8bb4313c7f", size = 260176, upload-time = "2026-07-12T20:29:07.082Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/19/14/2c5dd9f512b66549ae92767a9c7b330ae88e1932ca57876909410251fe13/anyio-4.13.0.tar.gz", hash = "sha256:334b70e641fd2221c1505b3890c69882fe4a2df910cba14d97019b90b24439dc", size = 231622, upload-time = "2026-03-24T12:59:09.671Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/da/35/f2287558c17e29fafc8ef3daf819bb9834061cfa43bff8014f7df7f63bdc/anyio-4.14.2-py3-none-any.whl", hash = "sha256:9f505dda5ac9f0c8309b5e8bd445a8c2bf7246f3ce950121e45ea15bc41d1494", size = 125813, upload-time = "2026-07-12T20:29:05.763Z" },
+    { url = "https://files.pythonhosted.org/packages/da/42/e921fccf5015463e32a3cf6ee7f980a6ed0f395ceeaa45060b61d86486c2/anyio-4.13.0-py3-none-any.whl", hash = "sha256:08b310f9e24a9594186fd75b4f73f4a4152069e3853f1ed8bfbf58369f4ad708", size = 114353, upload-time = "2026-03-24T12:59:08.246Z" },
 ]
 [[package]]
@@ -13,15 +13,15 @@ wheels = [
 [[package]]
 name = "anyio"
-version = "4.14.2"
+version = "4.13.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "idna" },
    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/61/cc/a381afa6efea9f496eff839d4a6a1aed3bfafc7b3ab4b0d1b243a12573dd/anyio-4.14.2.tar.gz", hash = "sha256:cfa139f3ed1a23ee8f88a145ddb5ac7605b8bbfd8592baacd7ce3d8bb4313c7f", size = 260176, upload-time = "2026-07-12T20:29:07.082Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/19/14/2c5dd9f512b66549ae92767a9c7b330ae88e1932ca57876909410251fe13/anyio-4.13.0.tar.gz", hash = "sha256:334b70e641fd2221c1505b3890c69882fe4a2df910cba14d97019b90b24439dc", size = 231622, upload-time = "2026-03-24T12:59:09.671Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/da/35/f2287558c17e29fafc8ef3daf819bb9834061cfa43bff8014f7df7f63bdc/anyio-4.14.2-py3-none-any.whl", hash = "sha256:9f505dda5ac9f0c8309b5e8bd445a8c2bf7246f3ce950121e45ea15bc41d1494", size = 125813, upload-time = "2026-07-12T20:29:05.763Z" },
+    { url = "https://files.pythonhosted.org/packages/da/42/e921fccf5015463e32a3cf6ee7f980a6ed0f395ceeaa45060b61d86486c2/anyio-4.13.0-py3-none-any.whl", hash = "sha256:08b310f9e24a9594186fd75b4f73f4a4152069e3853f1ed8bfbf58369f4ad708", size = 114353, upload-time = "2026-03-24T12:59:08.246Z" },
 ]
 [[package]]
@@ -19,16 +19,16 @@ wheels = [
 [[package]]
 name = "anyio"
-version = "4.14.2"
+version = "4.13.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "exceptiongroup", marker = "python_full_version < '3.11'" },
    { name = "idna" },
    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/61/cc/a381afa6efea9f496eff839d4a6a1aed3bfafc7b3ab4b0d1b243a12573dd/anyio-4.14.2.tar.gz", hash = "sha256:cfa139f3ed1a23ee8f88a145ddb5ac7605b8bbfd8592baacd7ce3d8bb4313c7f", size = 260176, upload-time = "2026-07-12T20:29:07.082Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/19/14/2c5dd9f512b66549ae92767a9c7b330ae88e1932ca57876909410251fe13/anyio-4.13.0.tar.gz", hash = "sha256:334b70e641fd2221c1505b3890c69882fe4a2df910cba14d97019b90b24439dc", size = 231622, upload-time = "2026-03-24T12:59:09.671Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/da/35/f2287558c17e29fafc8ef3daf819bb9834061cfa43bff8014f7df7f63bdc/anyio-4.14.2-py3-none-any.whl", hash = "sha256:9f505dda5ac9f0c8309b5e8bd445a8c2bf7246f3ce950121e45ea15bc41d1494", size = 125813, upload-time = "2026-07-12T20:29:05.763Z" },
+    { url = "https://files.pythonhosted.org/packages/da/42/e921fccf5015463e32a3cf6ee7f980a6ed0f395ceeaa45060b61d86486c2/anyio-4.13.0-py3-none-any.whl", hash = "sha256:08b310f9e24a9594186fd75b4f73f4a4152069e3853f1ed8bfbf58369f4ad708", size = 114353, upload-time = "2026-03-24T12:59:08.246Z" },
 ]
 [[package]]
@@ -12,23 +12,15 @@ from typing import (
    Generic,
    Literal,
    NamedTuple,
    TypeVar,
    final,
    overload,
 )
 from warnings import warn
 from langchain_core.messages import AnyMessage
 from langchain_core.runnables import Runnable, RunnableConfig
 from langgraph.checkpoint.base import BaseCheckpointSaver, CheckpointMetadata
-from pydantic import TypeAdapter
+from typing_extensions import NotRequired, TypeAliasType, TypedDict, Unpack, deprecated
 from typing_extensions import (
    NotRequired,
    TypeAliasType,
    TypedDict,
    TypeVar,
    Unpack,
    deprecated,
 )
 from xxhash import xxh3_128_hexdigest
 from langgraph._internal._cache import default_cache_key
@@ -44,7 +36,6 @@ from langgraph.warnings import LangGraphDeprecatedSinceV10, LangGraphDeprecatedS
 # when used in standalone type aliases.
 StateT = TypeVar("StateT")
 OutputT = TypeVar("OutputT")
 ResponseT = TypeVar("ResponseT", default=Any)
 if TYPE_CHECKING:
    from langgraph.pregel.protocol import PregelProtocol
@@ -581,7 +572,7 @@ _DEFAULT_INTERRUPT_ID = "placeholder-id"
@final
@dataclass(init=False, slots=True)
-class Interrupt(Generic[ResponseT]):
+class Interrupt:
    """Information about an interrupt that occurred in a node.
    !!! version-added "Added in version 0.2.24"
@@ -605,22 +596,13 @@ class Interrupt(Generic[ResponseT]):
    id: str
    """The ID of the interrupt. Can be used to resume the interrupt directly."""
    response_schema: type[ResponseT] | dict[str, Any] | None = None
    """Schema for the value expected when resuming this interrupt, if the graph provided one.
    A surfaced interrupt carries JSON Schema (a `dict`); `type[ResponseT]` records the
    Python type at construction so `Interrupt[Decision]` is meaningful to type checkers."""
    def __init__(
        self,
        value: Any,
        id: str = _DEFAULT_INTERRUPT_ID,
        *,
        response_schema: type[ResponseT] | dict[str, Any] | None = None,
        **deprecated_kwargs: Unpack[DeprecatedKwargs],
    ) -> None:
        self.value = value
        self.response_schema = response_schema
        if (
            (ns := deprecated_kwargs.get("ns", MISSING)) is not MISSING
@@ -632,18 +614,8 @@ class Interrupt(Generic[ResponseT]):
            self.id = id
    @classmethod
-    def from_ns(
+    def from_ns(cls, value: Any, ns: str) -> Interrupt:
-        cls,
+        return cls(value=value, id=xxh3_128_hexdigest(ns.encode()))
        value: Any,
        ns: str,
        *,
        response_schema: type[ResponseT] | dict[str, Any] | None = None,
    ) -> Interrupt[ResponseT]:
        return cls(
            value=value,
            id=xxh3_128_hexdigest(ns.encode()),
            response_schema=response_schema,
        )
    @property
    @deprecated("`interrupt_id` is deprecated. Use `id` instead.", category=None)
@@ -876,17 +848,7 @@ class Command(Generic[N], ToolOutputMixin):
    PARENT: ClassVar[Literal["__parent__"]] = "__parent__"
-@overload
+def interrupt(value: Any) -> Any:
 def interrupt(value: Any, *, response_schema: type[ResponseT]) -> ResponseT: ...
@overload
 def interrupt(value: Any, *, response_schema: dict[str, Any] | None = None) -> Any: ...
 def interrupt(
    value: Any, *, response_schema: dict[str, Any] | type | None = None
 ) -> Any:
    """Interrupt the graph with a resumable exception from within a node.
    The `interrupt` function enables human-in-the-loop workflows by pausing graph
@@ -956,7 +918,7 @@ def interrupt(
        for chunk in graph.stream({\"foo\": \"abc\"}, config):
            print(chunk)
-        # > {'__interrupt__': (Interrupt(value='what is your age?', id='45fda8478b2ef754419799e10992af06', response_schema=None),)}
+        # > {'__interrupt__': (Interrupt(value='what is your age?', id='45fda8478b2ef754419799e10992af06'),)}
        command = Command(resume=\"some input from a human!!!\")
@@ -969,20 +931,12 @@ def interrupt(
    Args:
        value: The value to surface to the client when the graph is interrupted.
        response_schema: Optional schema for the value expected on resume, surfaced
            to clients so they can render a typed input form. Accepts a JSON Schema
            `dict` (used as-is, resume values are not validated), or a Pydantic model
            class, `TypedDict`, or dataclass, which are converted to JSON Schema for
            clients and used to validate the resume value; the validated object is
            what `interrupt` returns.
    Returns:
-        Any: On subsequent invocations within the same node (same task to be precise), returns the value provided during the first invocation,
+        Any: On subsequent invocations within the same node (same task to be precise), returns the value provided during the first invocation
            validated against `response_schema` when one that supports validation was given.
    Raises:
        GraphInterrupt: On the first invocation within the node, halts execution and surfaces the provided value to the client.
        pydantic.ValidationError: When a resume value does not match a Pydantic model, `TypedDict`, or dataclass `response_schema`.
    """
    from langgraph._internal._constants import (
        CONFIG_KEY_CHECKPOINT_NS,
@@ -994,36 +948,27 @@ def interrupt(
    from langgraph.errors import GraphInterrupt
    conf = get_config()["configurable"]
    adapter = (
        None
        if response_schema is None or isinstance(response_schema, dict)
        else TypeAdapter(response_schema)
    )
    # track interrupt index
    scratchpad = conf[CONFIG_KEY_SCRATCHPAD]
    idx = scratchpad.interrupt_counter()
    # find previous resume values
    if scratchpad.resume:
        if idx < len(scratchpad.resume):
-            v = scratchpad.resume[idx]
+            conf[CONFIG_KEY_SEND]([(RESUME, scratchpad.resume)])
-            validated = adapter.validate_python(v) if adapter else v
+            return scratchpad.resume[idx]
            conf[CONFIG_KEY_SEND]([(RESUME, scratchpad.resume[: idx + 1])])
            return validated
    # find current resume value
    v = scratchpad.get_null_resume(True)
    if v is not None:
        assert len(scratchpad.resume) == idx, (scratchpad.resume, idx)
        validated = adapter.validate_python(v) if adapter else v
        scratchpad.resume.append(v)
        conf[CONFIG_KEY_SEND]([(RESUME, scratchpad.resume)])
-        return validated
+        return v
    # no resume value found
    raise GraphInterrupt(
        (
            Interrupt.from_ns(
                value=value,
                ns=conf[CONFIG_KEY_CHECKPOINT_NS],
                response_schema=adapter.json_schema() if adapter else response_schema,
            ),
        )
    )
@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 [project]
 name = "langgraph"
-version = "1.2.12"
+version = "1.2.11"
 description = "Building stateful, multi-actor applications with LLMs"
 authors = []
 requires-python = ">=3.10"
@@ -1,83 +0,0 @@
 """`DeltaChannel` replay must apply parallel writes in the order `invoke` did."""
 from typing import Annotated, Any
 import pytest
 from langgraph.checkpoint.base import BaseCheckpointSaver
 from typing_extensions import TypedDict
 from langgraph.channels.delta import DeltaChannel
 from langgraph.graph import END, START, StateGraph
 pytestmark = pytest.mark.anyio
 # Sorted, because live execution applies PULL tasks in node-name order.
 FAN_OUT_NAMES = ["a", "b", "c", "d", "e", "f", "g", "h"]
 def _append_reducer(current: list, updates: list) -> list:
    return [*current, *(x for u in updates for x in u)]
 def _build_fan_out_graph(checkpointer: BaseCheckpointSaver) -> Any:
    class State(TypedDict):
        items: Annotated[
            list, DeltaChannel(_append_reducer, list, snapshot_frequency=10_000)
        ]
    def make_node(label: str) -> Any:
        return lambda state: {"items": [label]}
    builder = StateGraph(State)
    for name in FAN_OUT_NAMES:
        builder.add_node(name, make_node(name))
        builder.add_edge(START, name)
        builder.add_edge(name, END)
    return builder.compile(checkpointer=checkpointer)
 async def test_get_state_matches_live_invoke_order(
    async_checkpointer: BaseCheckpointSaver,
 ) -> None:
    graph = _build_fan_out_graph(async_checkpointer)
    config = {"configurable": {"thread_id": "1"}}
    live = (await graph.ainvoke({"items": []}, config))["items"]
    replayed = (await graph.aget_state(config)).values["items"]
    assert live == FAN_OUT_NAMES
    assert replayed == live
 async def test_continuing_thread_preserves_committed_prefix(
    async_checkpointer: BaseCheckpointSaver,
 ) -> None:
    graph = _build_fan_out_graph(async_checkpointer)
    config = {"configurable": {"thread_id": "1"}}
    first = (await graph.ainvoke({"items": []}, config))["items"]
    second = (await graph.ainvoke({"items": []}, config))["items"]
    assert second == first + first
    assert (await graph.aget_state(config)).values["items"] == second
 async def test_state_history_reports_live_order_at_every_step(
    async_checkpointer: BaseCheckpointSaver,
 ) -> None:
    runs = 3
    graph = _build_fan_out_graph(async_checkpointer)
    config = {"configurable": {"thread_id": "1"}}
    for _ in range(runs):
        await graph.ainvoke({"items": []}, config)
    live = FAN_OUT_NAMES * runs
    seen = [
        s.values["items"]
        async for s in graph.aget_state_history(config)
        if "items" in s.values
    ]
    assert max(map(len, seen)) == len(live)
    for values in seen:
        assert values == live[: len(values)], f"{values} is not a prefix of {live}"
@@ -1,14 +1,9 @@
 from dataclasses import dataclass
 from typing import Any
 import pytest
 from langgraph.checkpoint.base import BaseCheckpointSaver
 from pydantic import BaseModel, ValidationError
 from typing_extensions import TypedDict
 from langgraph.graph import END, START, StateGraph
-from langgraph.types import Command, Durability, Interrupt, interrupt
+from langgraph.types import Durability
 from tests.any_str import AnyStr
 pytestmark = pytest.mark.anyio
@@ -95,150 +90,3 @@ async def test_interruption_without_state_updates_async(
    assert (await graph.aget_state(thread)).next == ()
    n_checkpoints = len([c async for c in graph.aget_state_history(thread)])
    assert n_checkpoints == (5 if durability != "exit" else 3)
 class Decision(BaseModel):
    approved: bool
    note: str | None = None
 class DecisionDict(TypedDict):
    approved: bool
@dataclass
 class DecisionData:
    approved: bool
 RAW_SCHEMA = {"type": "object", "properties": {"approved": {"type": "boolean"}}}
@pytest.mark.parametrize(
    ("response_schema", "expected_schema", "expected_answer"),
    [
        (None, None, {"approved": True, "extra": 1}),
        (RAW_SCHEMA, RAW_SCHEMA, {"approved": True, "extra": 1}),
        (Decision, Decision.model_json_schema(), Decision(approved=True)),
        (
            DecisionDict,
            {
                "properties": {"approved": {"title": "Approved", "type": "boolean"}},
                "required": ["approved"],
                "title": "DecisionDict",
                "type": "object",
            },
            {"approved": True},
        ),
        (
            DecisionData,
            {
                "properties": {"approved": {"title": "Approved", "type": "boolean"}},
                "required": ["approved"],
                "title": "DecisionData",
                "type": "object",
            },
            DecisionData(approved=True),
        ),
    ],
    ids=["none", "raw_dict", "pydantic", "typeddict", "dataclass"],
 )
 def test_interrupt_response_schema(
    sync_checkpointer: BaseCheckpointSaver,
    response_schema: Any,
    expected_schema: dict[str, Any] | None,
    expected_answer: Any,
 ) -> None:
    class State(TypedDict):
        answer: Any
    def node(state: State) -> State:
        return {
            "answer": interrupt(
                {"question": "approve?"}, response_schema=response_schema
            )
        }
    graph = (
        StateGraph(State)
        .add_node("node", node)
        .add_edge(START, "node")
        .compile(checkpointer=sync_checkpointer)
    )
    config = {"configurable": {"thread_id": "1"}}
    expected = Interrupt(
        value={"question": "approve?"}, id=AnyStr(), response_schema=expected_schema
    )
    assert list(graph.stream({"answer": None}, config)) == [
        {"__interrupt__": (expected,)}
    ]
    assert graph.get_state(config).tasks[0].interrupts == (expected,)
    assert graph.invoke(Command(resume={"approved": True, "extra": 1}), config) == {
        "answer": expected_answer
    }
@pytest.mark.parametrize("resume_style", ["null", "map"])
 def test_interrupt_response_schema_rejects_invalid_resume(
    sync_checkpointer: BaseCheckpointSaver, resume_style: str
 ) -> None:
    class State(TypedDict):
        answer: Any
    def node(state: State) -> State:
        return {"answer": interrupt("approve?", response_schema=Decision)}
    graph = (
        StateGraph(State)
        .add_node("node", node)
        .add_edge(START, "node")
        .compile(checkpointer=sync_checkpointer)
    )
    config = {"configurable": {"thread_id": "1"}}
    graph.invoke({"answer": None}, config)
    [pending] = graph.get_state(config).tasks[0].interrupts
    def resume(value: dict[str, Any]) -> Command:
        return Command(resume=value if resume_style == "null" else {pending.id: value})
    with pytest.raises(ValidationError, match="approved"):
        graph.invoke(resume({"approved": "nope"}), config)
    assert graph.invoke(resume({"approved": False}), config) == {
        "answer": Decision(approved=False)
    }
@pytest.mark.parametrize("resume_style", ["null", "id_map"])
 def test_interrupt_response_schema_invalid_resume_after_earlier_interrupt(
    sync_checkpointer: BaseCheckpointSaver, resume_style: str
 ) -> None:
    class State(TypedDict):
        answer: Any
    def node(state: State) -> State:
        first = interrupt("first")
        second = interrupt("approve?", response_schema=Decision)
        return {"answer": [first, second]}
    graph = (
        StateGraph(State)
        .add_node("node", node)
        .add_edge(START, "node")
        .compile(checkpointer=sync_checkpointer)
    )
    config = {"configurable": {"thread_id": "1"}}
    graph.invoke({"answer": None}, config)
    graph.invoke(Command(resume="ok"), config)
    [pending] = graph.get_state(config).tasks[0].interrupts
    def resume(value: dict[str, Any]) -> Command:
        return Command(resume=value if resume_style == "null" else {pending.id: value})
    with pytest.raises(ValidationError, match="approved"):
        graph.invoke(resume({"approved": "nope"}), config)
    assert graph.invoke(resume({"approved": True}), config) == {
        "answer": ["ok", Decision(approved=True)]
    }
@@ -5583,7 +5583,6 @@ def test_falsy_return_from_task(sync_checkpointer: BaseCheckpointSaver):
                "interrupts": [
                    {
                        "id": AnyStr(),
                        "response_schema": None,
                        "value": "test",
                    },
                ],
@@ -5628,7 +5627,6 @@ def test_falsy_return_from_task(sync_checkpointer: BaseCheckpointSaver):
                        "interrupts": (
                            {
                                "id": AnyStr(),
                                "response_schema": None,
                                "value": "test",
                            },
                        ),
@@ -1437,7 +1437,7 @@ wheels = [
 [[package]]
 name = "langgraph"
-version = "1.2.12"
+version = "1.2.11"
 source = { editable = "." }
 dependencies = [
    { name = "langchain-core" },
@@ -3404,11 +3404,11 @@ wheels = [
 [[package]]
 name = "soupsieve"
-version = "2.9"
+version = "2.8.4"
 source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/80/f1/93422647dd7e461f23d254e6b2bfa687a85b53aeb4903fcdbb74474d4584/soupsieve-2.9.tar.gz", hash = "sha256:acee8417325c5653e1377dc31eccad59eb82cbc65942afe6174c53b3aaad63fc", size = 122122, upload-time = "2026-07-19T01:35:18.425Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/47/2c/0a5f6f8ee0d5589e48c7640213ed5175d52cf540a06725b628cc1a45d6ce/soupsieve-2.8.4.tar.gz", hash = "sha256:e121fd02e975c695e4e9e8774a5ee35d74714b59307868dcc5319ad2d9e3328e", size = 121110, upload-time = "2026-05-24T13:55:57.154Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/7b/d6/3185ab5ad1280319b31986898f3206dd7227cd75e293d4dba2a5e6bf27a0/soupsieve-2.9-py3-none-any.whl", hash = "sha256:a2b2c76d67df2382d245409fd71e321a571717e58463efa32ace87dcadac2c12", size = 37387, upload-time = "2026-07-19T01:35:17.106Z" },
+    { url = "https://files.pythonhosted.org/packages/5e/f5/0c41cb68dcae6b7de4fac4188a3a9589e21fb31df21ea3a2e888db95e6c9/soupsieve-2.8.4-py3-none-any.whl", hash = "sha256:e7e6b0769c8f51ed59acab6e994b00621096cfb1c640a7509295987388fbaf65", size = 37304, upload-time = "2026-05-24T13:55:55.406Z" },
 ]
 [[package]]
@@ -286,7 +286,7 @@ wheels = [
 [[package]]
 name = "langgraph"
-version = "1.2.12"
+version = "1.2.11"
 source = { editable = "../langgraph" }
 dependencies = [
    { name = "langchain-core" },
@@ -3,7 +3,7 @@ from langgraph_sdk.client import get_client, get_sync_client
 from langgraph_sdk.encryption import Encryption
 from langgraph_sdk.encryption.types import DecryptResult, EncryptionContext
-__version__ = "0.4.5"
+__version__ = "0.4.4"
 __all__ = [
    "Auth",
@@ -295,8 +295,6 @@ class Interrupt(TypedDict):
    """The value associated with the interrupt."""
    id: str
    """The ID of the interrupt. Can be used to resume the interrupt."""
    response_schema: NotRequired[dict[str, Any]]
    """JSON Schema for the value expected when resuming this interrupt, if the graph provided one."""
 class Thread(TypedDict):
@@ -29,10 +29,7 @@ def test_sync_extension_projection_yields_matching_custom_payloads():
        {"name": "progress", "step": 1},
        {"name": "progress", "step": 2},
    ]
-    assert any(
+    assert "custom:progress" in fake.stream_request_bodies[-1]["channels"]
        "custom:progress" in body.get("channels", [])
        for body in fake.stream_request_bodies
    )
 def test_sync_extension_projection_supports_namespace_scope_on_subgraph_handle():
@@ -17,16 +17,16 @@ wheels = [
 [[package]]
 name = "anyio"
-version = "4.15.1"
+version = "4.12.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "exceptiongroup", marker = "python_full_version < '3.11'" },
    { name = "idna" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.15'" },
+    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/a9/d2/f4d173e22df740bc37b1db102b386ba719b66e95b0f0d751f556b387e6d2/anyio-4.15.1.tar.gz", hash = "sha256:9f28306018cbd6d329e64a36d58256edff76dd996fe423bc957326e578b82a94", size = 276966, upload-time = "2026-09-05T10:42:39.44Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/96/f0/5eb65b2bb0d09ac6776f2eb54adee6abe8228ea05b20a5ad0e4945de8aac/anyio-4.12.1.tar.gz", hash = "sha256:41cfcc3a4c85d3f05c932da7c26d0201ac36f72abd4435ba90d0464a3ffed703", size = 228685, upload-time = "2026-01-06T11:45:21.246Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/12/b8/4bd346e22b28902df4d651910f5242c28d84e4a5c2435ca5c3f797ed7e2e/anyio-4.15.1-py3-none-any.whl", hash = "sha256:6152fdbbf9a77fdec97731721bebf7c4c44f7c29b424b0065826173efc7ed101", size = 132079, upload-time = "2026-09-05T10:42:37.923Z" },
+    { url = "https://files.pythonhosted.org/packages/38/0e/27be9fdef66e72d64c0cdc3cc2823101b80585f8119b5c112c2e8f5f7dab/anyio-4.12.1-py3-none-any.whl", hash = "sha256:d405828884fc140aa80a3c667b8beed277f1dfedec42ba031bd6ac3db606ab6c", size = 113592, upload-time = "2026-01-06T11:45:19.497Z" },
 ]
 [[package]]
@@ -181,7 +181,7 @@ name = "exceptiongroup"
 version = "1.3.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/50/79/66800aadf48771f6b62f7eb014e352e5d06856655206165d775e675a02c9/exceptiongroup-1.3.1.tar.gz", hash = "sha256:8b412432c6055b0b7d14c310000ae93352ed6754f70fa8f7c34141f91c4e3219", size = 30371, upload-time = "2025-11-21T23:01:54.787Z" }
 wheels = [
@@ -277,8 +277,7 @@ dependencies = [
    { name = "pydantic" },
    { name = "pyyaml" },
    { name = "tenacity" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.15'" },
+    { name = "typing-extensions" },
    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.15'" },
    { name = "uuid-utils" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/90/12/aff76ca89c219ebe6f9dd3c5dbc4e3b1cf5450e9fc7037dccad23d45cd7a/langchain_core-1.6.1.tar.gz", hash = "sha256:1b156cb395aac4f009a8a1b38a574c7d948fe2d5f74c96e0d8a5017b4149e04f", size = 1003359, upload-time = "2026-08-27T19:31:14.956Z" }
@@ -291,8 +290,7 @@ name = "langchain-protocol"
 version = "0.0.19"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.15'" },
+    { name = "typing-extensions" },
    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.15'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/14/56/913599f2f9cec8524868929f12d72b2ede377a6056ca8a40a32bdadfa535/langchain_protocol-0.0.19.tar.gz", hash = "sha256:79d90a1425122ac87e8052e2ec054fbd09c3edbf341bdfb6397112a495c7bf8c", size = 6265, upload-time = "2026-08-26T21:12:00.703Z" }
 wheels = [
@@ -301,7 +299,7 @@ wheels = [
 [[package]]
 name = "langgraph"
-version = "1.2.12"
+version = "1.2.11"
 source = { editable = "../langgraph" }
 dependencies = [
    { name = "langchain-core" },
@@ -728,8 +726,7 @@ source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "annotated-types" },
    { name = "pydantic-core" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.15'" },
+    { name = "typing-extensions" },
    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.15'" },
    { name = "typing-inspection" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/53/ef/fc4f868f4e2cee79f863883abffceff107875f569b848507319842d2a681/pydantic-2.13.5.tar.gz", hash = "sha256:51a9c5f7b2f8e636f04c6cada605d9b6a3bf1348fdf945a3d8869b19bba0ee08", size = 845750, upload-time = "2026-08-28T14:04:00.916Z" }
@@ -742,8 +739,7 @@ name = "pydantic-core"
 version = "2.46.5"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.15'" },
+    { name = "typing-extensions" },
    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.15'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/af/f9/8a06bea35ef8daf588f707784c973a7046e0034c8d8cfb08828eeffb8b75/pydantic_core-2.46.5.tar.gz", hash = "sha256:10416c15b8839ecc4ef4d0885da76da6fd0f67333a0eb8aff6d93c4b8f2910fc", size = 472262, upload-time = "2026-08-28T10:01:31.677Z" }
 wheels = [
@@ -888,7 +884,7 @@ source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "backports-asyncio-runner", marker = "python_full_version < '3.11'" },
    { name = "pytest" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.13'" },
+    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/43/7c/d36d04db312ecf4298932ef77e6e4a9e8ad017906e24e34f0b0c361a2473/pytest_asyncio-1.4.0.tar.gz", hash = "sha256:c6c0d2259945122819f171a32ecea2c349ead889ee28176caaf492143424be42", size = 58514, upload-time = "2026-05-26T09:56:04.083Z" }
 wheels = [
@@ -1041,7 +1037,7 @@ version = "1.6.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
    { name = "anyio" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.13'" },
+    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/b5/b4/205b0d5241d934e8add0c38aa924c4f9fb7330834ff11e5444db964ec3f9/starlette-1.6.0.tar.gz", hash = "sha256:d4e3ac5e546444960c710297a3c9fc3f7ebae1b7e963f3d36173b49da535be9b", size = 2716969, upload-time = "2026-08-08T18:27:57.512Z" }
 wheels = [
@@ -1140,33 +1136,17 @@ wheels = [
 name = "typing-extensions"
 version = "4.15.0"
 source = { registry = "https://pypi.org/simple" }
 resolution-markers = [
    "python_full_version >= '3.15'",
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/72/94/1a15dd82efb362ac84269196e94cf00f187f7ed21c242792a923cdb1c61f/typing_extensions-4.15.0.tar.gz", hash = "sha256:0cea48d173cc12fa28ecabc3b837ea3cf6f38c6d1136f85cbaaf598984861466", size = 109391, upload-time = "2025-08-25T13:49:26.313Z" }
 wheels = [
    { url = "https://files.pythonhosted.org/packages/18/67/36e9267722cc04a6b9f15c7f3441c2363321a3ea07da7ae0c0707beb2a9c/typing_extensions-4.15.0-py3-none-any.whl", hash = "sha256:f0fa19c6845758ab08074a0cfa8b7aecb71c999ca73d62883bc25cc018c4e548", size = 44614, upload-time = "2025-08-25T13:49:24.86Z" },
 ]
 [[package]]
 name = "typing-extensions"
 version = "4.16.0"
 source = { registry = "https://pypi.org/simple" }
 resolution-markers = [
    "python_full_version < '3.15'",
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/f6/cc/6253133b5bb138fc3306cebfbda2c520f545d36b5be2c7255cc528bb45d6/typing_extensions-4.16.0.tar.gz", hash = "sha256:dc983d19a509c94dba722ee6abd33940f7c05a89e243c47e907eb4db6f1a43e5", size = 113555, upload-time = "2026-07-02T08:40:05.92Z" }
 wheels = [
    { url = "https://files.pythonhosted.org/packages/49/d3/b8441a820a491ddfc024b0b0cf0393375b75ea13866d9c66727e54c2fc80/typing_extensions-4.16.0-py3-none-any.whl", hash = "sha256:481caa481374e813c1b176ada14e97f1f67a4539ce9cfeb3f350d78d6370c2e8", size = 45571, upload-time = "2026-07-02T08:40:04.659Z" },
 ]
 [[package]]
 name = "typing-inspection"
 version = "0.4.2"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.15'" },
+    { name = "typing-extensions" },
    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.15'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/55/e3/70399cb7dd41c10ac53367ae42139cf4b1ca5f36bb3dc6c9d33acdb43655/typing_inspection-0.4.2.tar.gz", hash = "sha256:ba561c48a67c5958007083d386c3295464928b01faa735ab8547c5692e87f464", size = 75949, upload-time = "2025-10-01T02:14:41.687Z" }
 wheels = [
Author	SHA1	Message	Date
Rafid Saad	5cac7783bd	refactor(cli): simplify tenant ID helper	2026-09-13 14:14:43 -07:00
Rafid Saad	1bf8293d38	refactor(cli): extract tenant ID resolution	2026-09-13 14:11:07 -07:00
Rafid Saad	d85ae52b85	refactor(cli): resolve workspace alias into tenant_id	2026-09-13 14:08:58 -07:00
Rafid Saad	3a6885d58c	fix(cli): reject simultaneous workspace variables	2026-09-13 14:04:49 -07:00
Rafid Saad	48051304a9	fix(cli): keep workspace alias changes minimal	2026-09-13 14:02:55 -07:00
Rafid Saad	c416b6561c	fix(cli): support LANGSMITH_WORKSPACE_ID for deployments	2026-09-13 13:49:01 -07:00