fix(cli): read every page when listing listeners

libs/cli/generate_schema.py

@@ -23,7 +23,6 @@ from langgraph_cli.schemas import (
     GraphDef,
     HttpConfig,
     IndexConfig,
-    PriorityConfig,
     SecurityConfig,
     SerdeConfig,
     StoreConfig,
@@ -114,7 +113,6 @@ def add_descriptions_to_schema(schema, cls):
                 StoreConfig,
                 IndexConfig,
                 AuthConfig,
-                PriorityConfig,
                 SecurityConfig,
                 HttpConfig,
                 CorsConfig,

libs/cli/js-examples/yarn.lock

@@ -5217,6 +5217,6 @@ yocto-queue@^0.1.0:
   integrity sha512-rVksvsnNCdJ/ohGc6xgPwyN8eheCxsiLM8mxuE/t/mOVqJewPuO1miLpTHQiRgTKCLexL4MeAFVagts7HmNZ2Q==
 
 "zod@^3.25.76 || ^4":
-  version "4.6.7"
-  resolved "https://registry.yarnpkg.com/zod/-/zod-4.6.7.tgz#e806cf64a7f4e37635ce9f2f52c04c3766f75e5b"
-  integrity sha512-g8W2D2kU6a8untc053fX1uVBKzM7yqAxW/3zwk83+6RyF2+SKOuV+c0wBDhUwzV1PaGapmZH+rmcUzPf+3CGwg==
+  version "4.3.6"
+  resolved "https://registry.yarnpkg.com/zod/-/zod-4.3.6.tgz#89c56e0aa7d2b05107d894412227087885ab112a"
+  integrity sha512-rftlrkhHZOcjDwkGlnUtZZkvaPHCsDATp4pGpuOOMDaTdDDXF91wuVDJoWoPsKX/3YPQ5fHuF3STjcYyKr+Qhg==

libs/cli/langgraph_cli/__init__.py

@@ -1 +1 @@
-__version__ = "0.4.38"
+__version__ = "0.4.37"

libs/cli/langgraph_cli/cli.py

@@ -847,7 +847,6 @@ def dev(
         store=config_json.get("store"),
         wait_for_client=wait_for_client,
         auth=config_json.get("auth"),
-        priority=config_json.get("priority"),
         http=config_json.get("http"),
         ui=config_json.get("ui"),
         ui_config=config_json.get("ui_config"),

libs/cli/langgraph_cli/config.py

@@ -442,7 +442,6 @@ def validate_config(
         "store": config.get("store"),
         "auth": config.get("auth"),
         "encryption": config.get("encryption"),
-        "priority": config.get("priority"),
         "http": config.get("http"),
         # Pass through webhooks config so it can be injected into the image
         "webhooks": config.get("webhooks"),
@@ -607,19 +606,6 @@ def validate_config(
                     f"Invalid encryption.path format: '{encryption_conf['path']}'. "
                     "Must be in format './path/to/file.py:attribute_name'"
                 )
-    # Validate priority config
-    if priority_conf := config.get("priority"):
-        if "path" in priority_conf:
-            if ":" not in priority_conf["path"]:
-                raise ValueError(
-                    f"Invalid priority.path format: '{priority_conf['path']}'. "
-                    "Must be in format './path/to/file.py:attribute_name'"
-                )
-            if _is_node_graph(priority_conf["path"]):
-                raise ValueError(
-                    "JavaScript priority callbacks are not supported: "
-                    f"'{priority_conf['path']}'. Use a Python file or module instead."
-                )
     if http_conf := config.get("http"):
         if "app" in http_conf:
             if ":" not in http_conf["app"]:
@@ -663,7 +649,6 @@ _KNOWN_CONFIG_KEYS = {
     "store",
     "auth",
     "encryption",
-    "priority",
     "http",
     "webhooks",
     "checkpointer",
@@ -1095,49 +1080,6 @@ def _update_encryption_path(
     )
 
 
-def _update_priority_path(
-    config_path: pathlib.Path, config: Config, local_deps: LocalDeps
-) -> None:
-    """Update priority.path to use Docker container paths."""
-    priority_conf = config.get("priority")
-    if not priority_conf or not (path_str := priority_conf.get("path")):
-        return
-
-    module_str, sep, attr_str = path_str.partition(":")
-    if not sep or not module_str.startswith("."):
-        return  # Already validated or absolute path
-
-    resolved = config_path.parent / module_str
-    if not resolved.exists():
-        raise FileNotFoundError(
-            f"Priority file not found: {resolved} (from {path_str})"
-        )
-    if not resolved.is_file():
-        raise IsADirectoryError(f"Priority path must be a file: {resolved}")
-
-    # Check faux packages first (they take precedence)
-    for faux_path, (_, destpath) in local_deps.faux_pkgs.items():
-        if resolved.is_relative_to(faux_path):
-            new_path = f"{destpath}/{resolved.relative_to(faux_path)}:{attr_str}"
-            priority_conf["path"] = new_path
-            return
-
-    # Check real packages
-    for real_path in local_deps.real_pkgs:
-        if resolved.is_relative_to(real_path):
-            new_path = (
-                f"/deps/{real_path.name}/{resolved.relative_to(real_path)}:{attr_str}"
-            )
-            priority_conf["path"] = new_path
-            return
-
-    raise ValueError(
-        f"Priority file '{resolved}' not covered by dependencies.\n"
-        "Add its parent directory to the 'dependencies' array in your config.\n"
-        f"Current dependencies: {config['dependencies']}"
-    )
-
-
 def _update_checkpointer_path(
     config_path: pathlib.Path, config: Config, local_deps: LocalDeps
 ) -> None:
@@ -1271,9 +1213,6 @@ def _build_runtime_env_vars(config: Config) -> list[str]:
     if (encryption_config := config.get("encryption")) is not None:
         env_vars.append(f"ENV LANGGRAPH_ENCRYPTION='{json.dumps(encryption_config)}'")
 
-    if (priority_config := config.get("priority")) is not None:
-        env_vars.append(f"ENV LANGGRAPH_PRIORITY='{json.dumps(priority_config)}'")
-
     if (http_config := config.get("http")) is not None:
         env_vars.append(f"ENV LANGGRAPH_HTTP='{json.dumps(http_config)}'")
 
@@ -1441,8 +1380,6 @@ def python_config_to_docker(
     _update_auth_path(config_path, config, local_deps)
     # Rewrite encryption path, so it points to the correct location in the Docker container
     _update_encryption_path(config_path, config, local_deps)
-    # Rewrite priority path, so it points to the correct location in the Docker container
-    _update_priority_path(config_path, config, local_deps)
     # Rewrite checkpointer path, so it points to the correct location in the Docker container
     _update_checkpointer_path(config_path, config, local_deps)
     # Rewrite HTTP app path, so it points to the correct location in the Docker container

libs/cli/langgraph_cli/deploy.py

@@ -26,7 +26,6 @@ from langgraph_cli.dependency_tracking import find_tracked_packages
 from langgraph_cli.docker import build_docker_image, can_build_locally
 from langgraph_cli.exec import CommandRunner, Runner, subp_exec
 from langgraph_cli.host_backend import (
-    MAX_PAGE_SIZE,
     ControlPlaneEndpoints,
     HostBackendClient,
     HostBackendError,
@@ -183,12 +182,15 @@ class Listener:
         )
         return cls(
             identifier,
-            str(resource.get("compute_id", "")),
+            str(resource.get("compute_id") or ""),
             tuple(str(namespace) for namespace in namespaces)
             if isinstance(namespaces, list)
             else (),
         )
 
+    def cells(self) -> tuple[str | None, ...]:
+        return (self.id, self.compute_id, ", ".join(self.namespaces))
+
 
 @dataclass(frozen=True, slots=True)
 class Unplaced:
@@ -276,8 +278,6 @@ def _describe_listeners(listeners: Sequence[Listener]) -> str:
     ]
     if len(listeners) > len(shown):
         lines.append(f"  ... and {len(listeners) - len(shown)} more")
-    if len(listeners) == MAX_PAGE_SIZE:
-        lines.append(f"  (only the first {MAX_PAGE_SIZE} listeners were read)")
     return "\n".join(lines)
 
 
@@ -499,16 +499,9 @@ def _source_of(resource: object) -> str | None:
 def find_deployment_by_name(
     client: HostBackendClient, name: str
 ) -> ExistingDeployment | None:
-    listed = client.list_deployments(name=name, name_contains=name, limit=MAX_PAGE_SIZE)
-    for resource in listed:
+    for resource in client.list_deployments(name=name, name_contains=name):
         if resource.get("name") == name and resource.get("id"):
             return ExistingDeployment(str(resource["id"]), _source_of(resource))
-    if len(listed) >= MAX_PAGE_SIZE:
-        raise click.ClickException(
-            "This workspace has more deployments than the CLI can search, so it "
-            f"cannot tell whether '{name}' already exists. Pass --deployment-id to "
-            "update an existing deployment."
-        )
     return None
 
 
@@ -583,103 +576,150 @@ def _validate_prebuilt_image(
     _get_emitter().info(f"Image is available for {_DEPLOYMENT_PLATFORM}")
 
 
-def _extract_deployment_url(deployment: dict[str, object]) -> str:
-    source_config = deployment.get("source_config")
-    if isinstance(source_config, dict):
-        custom_url = source_config.get("custom_url")
-        if isinstance(custom_url, str) and custom_url:
-            return custom_url
-    return "-"
+Resource = Mapping[str, object]
 
 
-def format_deployments_table(deployments: Sequence[dict[str, object]]) -> str:
-    headers = ("Deployment ID", "Deployment Name", "Deployment URL")
-    rows = [
-        (
-            str(deployment.get("id", "-") or "-"),
-            str(deployment.get("name", "-") or "-"),
-            _extract_deployment_url(deployment),
-        )
-        for deployment in deployments
-    ]
-    widths = [
-        max(len(headers[index]), *(len(row[index]) for row in rows))
-        for index in range(len(headers))
-    ]
+@dataclass(frozen=True, slots=True)
+class Table:
+    headers: tuple[str, ...]
+    cells: Callable[[Resource], tuple[str | None, ...]]
 
-    def format_row(row: Sequence[str]) -> str:
-        return "  ".join(value.ljust(widths[index]) for index, value in enumerate(row))
-
-    lines = [format_row(headers), format_row(tuple("-" * width for width in widths))]
-    lines.extend(format_row(row) for row in rows)
-    return "\n".join(lines)
-
-
-def _extract_listener_namespaces(listener: dict[str, object]) -> str:
-    compute_config = listener.get("compute_config")
-    namespaces = (
-        compute_config.get("k8s_namespaces")
-        if isinstance(compute_config, dict)
-        else None
-    )
-    if isinstance(namespaces, list) and namespaces:
-        return ", ".join(str(namespace) for namespace in namespaces)
-    return "-"
-
-
-def format_listeners_table(listeners: Sequence[dict[str, object]]) -> str:
-    headers = ("Listener ID", "Compute ID", "Namespaces")
-    rows = [
-        (
-            str(listener.get("id", "-") or "-"),
-            str(listener.get("compute_id", "-") or "-"),
-            _extract_listener_namespaces(listener),
-        )
-        for listener in listeners
-    ]
-    widths = [
-        max(len(headers[index]), *(len(row[index]) for row in rows))
-        for index in range(len(headers))
-    ]
-
-    def format_row(row: Sequence[str]) -> str:
-        return "  ".join(value.ljust(widths[index]) for index, value in enumerate(row))
-
-    lines = [format_row(headers), format_row(tuple("-" * width for width in widths))]
-    lines.extend(format_row(row) for row in rows)
-    return "\n".join(lines)
-
-
-def format_revisions_table(revisions: Sequence[dict[str, object]]) -> str:
-    headers = ("Revision ID", "Status", "Created At")
-    latest_deployed_seen = False
-    rows = []
-    for revision in revisions:
-        status = str(revision.get("status", "-") or "-")
-        if status == "DEPLOYED":
-            if latest_deployed_seen:
-                status = "REPLACED"
-            else:
-                latest_deployed_seen = True
-        rows.append(
-            (
-                str(revision.get("id", "-") or "-"),
-                status,
-                str(revision.get("created_at", "-") or "-"),
+    def render(self, resources: Sequence[Resource]) -> str:
+        grid = [
+            self.headers,
+            *(
+                tuple(cell or "-" for cell in self.cells(resource))
+                for resource in resources
+            ),
+        ]
+        widths = [max(map(len, column)) for column in zip(*grid, strict=True)]
+        rule = tuple("-" * width for width in widths)
+        return "\n".join(
+            "  ".join(
+                cell.ljust(width) for cell, width in zip(row, widths, strict=True)
             )
+            for row in (grid[0], rule, *grid[1:])
         )
 
-    widths = [
-        max(len(headers[index]), *(len(row[index]) for row in rows))
-        for index in range(len(headers))
+
+@dataclass(frozen=True, slots=True)
+class Listing:
+    table: Table
+    empty_message: str
+    json_view: Callable[[Resource], object]
+
+    def as_table(self, resources: Sequence[Resource]) -> str:
+        return self.table.render(resources) if resources else self.empty_message
+
+    def as_json(self, resources: Sequence[Resource]) -> str:
+        return json_mod.dumps([self.json_view(resource) for resource in resources])
+
+
+class ListOutput(Protocol):
+    @property
+    def no_input(self) -> bool: ...
+
+    def show(self, listing: Listing, resources: Sequence[Resource]) -> None: ...
+
+
+@dataclass(frozen=True, slots=True)
+class TableOutput:
+    @property
+    def no_input(self) -> bool:
+        return False
+
+    def show(self, listing: Listing, resources: Sequence[Resource]) -> None:
+        click.echo(listing.as_table(resources))
+
+
+@dataclass(frozen=True, slots=True)
+class JsonOutput:
+    @property
+    def no_input(self) -> bool:
+        return True
+
+    def show(self, listing: Listing, resources: Sequence[Resource]) -> None:
+        click.echo(listing.as_json(resources))
+
+
+def _text(resource: Resource, key: str) -> str | None:
+    value = resource.get(key)
+    return str(value) if value else None
+
+
+def _deployment_url(deployment: Resource) -> str | None:
+    source_config = deployment.get("source_config")
+    custom_url = (
+        source_config.get("custom_url") if isinstance(source_config, Mapping) else None
+    )
+    return custom_url if isinstance(custom_url, str) and custom_url else None
+
+
+def _with_replaced_status(revisions: Sequence[Resource]) -> list[Resource]:
+    live_index = next(
+        (
+            index
+            for index, revision in enumerate(revisions)
+            if revision.get("status") == "DEPLOYED"
+        ),
+        None,
+    )
+    return [
+        {**revision, "status": "REPLACED"}
+        if revision.get("status") == "DEPLOYED" and index != live_index
+        else revision
+        for index, revision in enumerate(revisions)
     ]
 
-    def format_row(row: Sequence[str]) -> str:
-        return "  ".join(value.ljust(widths[index]) for index, value in enumerate(row))
 
-    lines = [format_row(headers), format_row(tuple("-" * width for width in widths))]
-    lines.extend(format_row(row) for row in rows)
-    return "\n".join(lines)
+@dataclass(frozen=True, slots=True)
+class DeploymentRow:
+    id: str
+    name: str | None
+    url: str | None
+
+    @classmethod
+    def from_resource(cls, deployment: Resource) -> "DeploymentRow":
+        identifier = _text(deployment, "id")
+        if identifier is None:
+            raise HostBackendError(
+                "The control plane returned a deployment without an id."
+            )
+        return cls(identifier, _text(deployment, "name"), _deployment_url(deployment))
+
+    def cells(self) -> tuple[str | None, ...]:
+        return (self.id, self.name, self.url)
+
+    def as_json(self) -> dict[str, str | None]:
+        return {"id": self.id, "name": self.name}
+
+
+DEPLOYMENTS = Listing(
+    Table(
+        ("Deployment ID", "Deployment Name", "Deployment URL"),
+        lambda deployment: DeploymentRow.from_resource(deployment).cells(),
+    ),
+    empty_message="No deployments found.",
+    json_view=lambda deployment: DeploymentRow.from_resource(deployment).as_json(),
+)
+
+LISTENERS = Listing(
+    Table(
+        ("Listener ID", "Compute ID", "Namespaces"),
+        lambda listener: Listener.from_resource(listener).cells(),
+    ),
+    empty_message="No listeners found for this workspace.",
+    json_view=dict,
+)
+
+REVISIONS_TABLE = Table(
+    ("Revision ID", "Status", "Created At"),
+    lambda revision: (
+        _text(revision, "id"),
+        _text(revision, "status"),
+        _text(revision, "created_at"),
+    ),
+)
 
 
 def format_timestamp(ts) -> str:
@@ -841,7 +881,6 @@ def _find_deployment(
             lambda c: c.list_deployments(
                 agent_id=selector.agent_id,
                 agent_environment=selector.environment,
-                limit=MAX_PAGE_SIZE,
             ),
         )
         if len(existing) > 1:
@@ -1007,20 +1046,15 @@ def _print_deployment_result(
     dashboard_label: str,
     status_url: str | None = None,
 ) -> None:
-    """Print final deployment status and raise on failure."""
     em = _get_emitter()
-    dep_info = client.get_deployment(deployment_id)
-    custom_url = None
-    if isinstance(dep_info, dict):
-        sc = dep_info.get("source_config")
-        if isinstance(sc, dict):
-            custom_url = sc.get("custom_url")
+    deployment = client.get_deployment(deployment_id)
+    url = _deployment_url(deployment) if isinstance(deployment, Mapping) else None
 
     if last_status == "DEPLOYED":
         em.result(
             "succeeded",
             deployment_id=deployment_id,
-            url=custom_url,
+            url=url,
             status_url=status_url,
         )
     elif last_status in ("BUILD_FAILED", "DEPLOY_FAILED", "CREATE_FAILED"):
@@ -2120,6 +2154,21 @@ OPT_VERBOSE = click.option(
 )
 
 
+def _list_output(
+    _ctx: click.Context, _param: click.Parameter, as_json: bool
+) -> ListOutput:
+    return JsonOutput() if as_json else TableOutput()
+
+
+OPT_LIST_OUTPUT = click.option(
+    "--json",
+    "output",
+    is_flag=True,
+    callback=_list_output,
+    help="Print a JSON array instead of a table.",
+)
+
+
 class NestedHelpGroup(click.Group):
     """Click group that shows one level of nested subcommands in top-level help."""
 
@@ -2594,6 +2643,7 @@ def _deploy_cmd(
     default="",
     help="Only show deployments whose names contain this value.",
 )
+@OPT_LIST_OUTPUT
 @deploy.command("list", help="[Beta] List LangSmith Deployments.")
 def deploy_list(
     api_key: str | None,
@@ -2601,11 +2651,13 @@ def deploy_list(
     name_contains: str,
     agent_id: str | None,
     environment: str | None,
+    output: ListOutput,
 ) -> None:
     if agent_id is not None or environment is not None:
         click.secho(
             "Note: --agent-id and --agent-environment flags are in private beta",
             fg="yellow",
+            err=True,
         )
     if agent_id is not None and not agent_id.strip():
         raise click.UsageError("--agent-id must not be empty.")
@@ -2614,15 +2666,13 @@ def deploy_list(
         filters["agent_id"] = agent_id
     if environment is not None:
         filters["agent_environment"] = environment
-    client = _create_host_backend_client(host_url, api_key)
+    client = _create_host_backend_client(host_url, api_key, no_input=output.no_input)
     deployments = _call_host_backend_with_optional_tenant(
         client,
         lambda c: c.list_deployments(name_contains=name_contains, **filters),
+        no_input=output.no_input,
     )
-    if not deployments:
-        click.echo("No deployments found.")
-        return
-    click.echo(format_deployments_table(deployments))
+    output.show(DEPLOYMENTS, deployments)
 
 
 # ---------------------------------------------------------------------------
@@ -2641,13 +2691,7 @@ def deploy_listeners() -> None:
 
 @OPT_HOST_API_KEY
 @OPT_HOST_URL
-@click.option(
-    "--json",
-    "json_output",
-    is_flag=True,
-    default=False,
-    help="Emit the listeners as a JSON array instead of a table.",
-)
+@OPT_LIST_OUTPUT
 @deploy_listeners.command(
     "list",
     help=(
@@ -2657,19 +2701,13 @@ def deploy_listeners() -> None:
     ),
 )
 def deploy_listeners_list(
-    api_key: str | None, host_url: str | None, json_output: bool
+    api_key: str | None, host_url: str | None, output: ListOutput
 ) -> None:
-    client = _create_host_backend_client(host_url, api_key, no_input=json_output)
+    client = _create_host_backend_client(host_url, api_key, no_input=output.no_input)
     listeners = _call_host_backend_with_optional_tenant(
-        client, lambda c: c.list_listeners(), no_input=json_output
+        client, lambda c: c.list_listeners(), no_input=output.no_input
     )
-    if json_output:
-        click.echo(json_mod.dumps(listeners))
-        return
-    if not listeners:
-        click.echo("No listeners found for this workspace.")
-        return
-    click.echo(format_listeners_table(listeners))
+    output.show(LISTENERS, listeners)
 
 
 # ---------------------------------------------------------------------------
@@ -2712,7 +2750,7 @@ def deploy_revisions_list(
     if not revisions:
         click.echo(f"No revisions found for deployment {deployment_id}.")
         return
-    click.echo(format_revisions_table(revisions))
+    click.echo(REVISIONS_TABLE.render(_with_replaced_status(revisions)))
 
 
 # ---------------------------------------------------------------------------

libs/cli/langgraph_cli/host_backend.py

@@ -2,6 +2,7 @@
 
 from __future__ import annotations
 
+from collections.abc import Mapping
 from dataclasses import dataclass
 from typing import Any, Literal
 from urllib.parse import urlparse
@@ -220,27 +221,51 @@ class HostBackendClient:
         *,
         name: str | None = None,
         name_contains: str | None = None,
-        limit: int | None = None,
         agent_id: str | None = None,
         agent_environment: str | None = None,
-    ) -> list[dict[str, Any]]:
+    ) -> list[dict[str, object]]:
         given = (
             ("name", name),
             ("name_contains", name_contains),
-            ("limit", limit),
             ("agent_id", agent_id),
             ("agent_environment", agent_environment),
         )
-        params = {key: value for key, value in given if value is not None}
-        return _resources(self._request("GET", "/v2/deployments", params=params))
+        filters = {key: value for key, value in given if value is not None}
+        return self._every_page("/v2/deployments", filters)
+
+    def _every_page(
+        self, path: str, filters: Mapping[str, object]
+    ) -> list[dict[str, object]]:
+        resources: list[dict[str, object]] = []
+        seen_ids: set[object] = set()
+        while True:
+            page = _resources(
+                self._request(
+                    "GET",
+                    path,
+                    params={
+                        **filters,
+                        "limit": MAX_PAGE_SIZE,
+                        "offset": len(resources),
+                    },
+                )
+            )
+            page_ids = {resource.get("id") for resource in page}
+            if page_ids and page_ids <= seen_ids:
+                raise HostBackendError(
+                    f"GET {path} returned the same resources again: this control "
+                    "plane ignores 'offset', so the CLI cannot read past the first page."
+                )
+            seen_ids |= page_ids
+            resources.extend(page)
+            if len(page) < MAX_PAGE_SIZE:
+                return resources
 
     def get_listener(self, listener_id: str) -> dict[str, Any]:
         return self._request("GET", f"/v2/listeners/{listener_id}")
 
-    def list_listeners(self) -> list[dict[str, Any]]:
-        return _resources(
-            self._request("GET", "/v2/listeners", params={"limit": MAX_PAGE_SIZE})
-        )
+    def list_listeners(self) -> list[dict[str, object]]:
+        return self._every_page("/v2/listeners", {})
 
     def get_deployment(self, deployment_id: str) -> dict[str, Any]:
         return self._request("GET", f"/v2/deployments/{deployment_id}")

libs/cli/langgraph_cli/schemas.py

@@ -373,27 +373,6 @@ class EncryptionConfig(TypedDict, total=False):
     """
 
 
-class PriorityConfig(TypedDict, total=False):
-    """Configuration for custom run priority logic.
-
-    Allows you to decide each thread's priority settings with a Python function
-    that the server calls at the first run on a thread with no settings, which
-    can come long after the thread was created."""
-
-    path: str
-    """Required. Path to an instance of the Priority() class that registers an assign function.
-
-    Format: "path/to/file.py:my_priority"
-
-    Example:
-        {
-            "priority": {
-                "path": "./priority.py:my_priority"
-            }
-        }
-    """
-
-
 class CorsConfig(TypedDict, total=False):
     """Specifies Cross-Origin Resource Sharing (CORS) rules for your server.
 
@@ -774,13 +753,6 @@ class Config(TypedDict, total=False):
     Allows you to implement custom encryption for sensitive data stored in the database.
     """
 
-    priority: PriorityConfig | None
-    """Optional. Custom run priority config, including the path to your Python priority logic.
-
-    Allows you to decide each thread's priority settings at the first run on a thread with no settings,
-    which can come long after the thread was created.
-    """
-
     http: HttpConfig | None
     """Optional. Configuration for the built-in HTTP server, controlling which custom routes are exposed
     and how cross-origin requests are handled.
@@ -812,7 +784,6 @@ __all__ = [
     "CheckpointerConfig",
     "AuthConfig",
     "EncryptionConfig",
-    "PriorityConfig",
     "HttpConfig",
     "MiddlewareOrders",
     "Distros",

libs/cli/langgraph_cli/uv_lock.py

@@ -910,7 +910,6 @@ def python_config_to_docker_uv_lock(
     for section, key in [
         ("auth", "path"),
         ("encryption", "path"),
-        ("priority", "path"),
         ("checkpointer", "path"),
         ("http", "app"),
     ]:

libs/cli/schemas/schema.json

@@ -196,17 +196,6 @@
                 }
               ]
             },
-            "priority": {
-              "anyOf": [
-                {
-                  "$ref": "#/$defs/PriorityConfig"
-                },
-                {
-                  "type": "null"
-                }
-              ],
-              "description": "Optional. Custom run priority config, including the path to your Python priority logic.\n\nAllows you to decide each thread's priority settings at the first run on a thread with no settings,\nwhich can come long after the thread was created.\n"
-            },
             "source": {
               "anyOf": [
                 {
@@ -449,17 +438,6 @@
                 }
               ]
             },
-            "priority": {
-              "anyOf": [
-                {
-                  "$ref": "#/$defs/PriorityConfig"
-                },
-                {
-                  "type": "null"
-                }
-              ],
-              "description": "Optional. Custom run priority config, including the path to your Python priority logic.\n\nAllows you to decide each thread's priority settings at the first run on a thread with no settings,\nwhich can come long after the thread was created.\n"
-            },
             "source": {
               "$ref": "#/$defs/UvSource"
             },
@@ -688,17 +666,6 @@
                 }
               ]
             },
-            "priority": {
-              "anyOf": [
-                {
-                  "$ref": "#/$defs/PriorityConfig"
-                },
-                {
-                  "type": "null"
-                }
-              ],
-              "description": "Optional. Custom run priority config, including the path to your Python priority logic.\n\nAllows you to decide each thread's priority settings at the first run on a thread with no settings,\nwhich can come long after the thread was created.\n"
-            },
             "source": {
               "anyOf": [
                 {
@@ -1203,18 +1170,6 @@
       },
       "required": []
     },
-    "PriorityConfig": {
-      "title": "PriorityConfig",
-      "description": "Configuration for custom run priority logic.\n\nAllows you to decide each thread's priority settings with a Python function\nthat the server calls at the first run on a thread with no settings, which\ncan come long after the thread was created.",
-      "type": "object",
-      "properties": {
-        "path": {
-          "type": "string",
-          "description": "Required. Path to an instance of the Priority() class that registers an assign function.\n"
-        }
-      },
-      "required": []
-    },
     "UvSource": {
       "title": "UvSource",
       "description": "Deployment source rooted at a uv project or workspace.",

libs/cli/schemas/schema.v0.json

@@ -196,17 +196,6 @@
                 }
               ]
             },
-            "priority": {
-              "anyOf": [
-                {
-                  "$ref": "#/$defs/PriorityConfig"
-                },
-                {
-                  "type": "null"
-                }
-              ],
-              "description": "Optional. Custom run priority config, including the path to your Python priority logic.\n\nAllows you to decide each thread's priority settings at the first run on a thread with no settings,\nwhich can come long after the thread was created.\n"
-            },
             "source": {
               "anyOf": [
                 {
@@ -449,17 +438,6 @@
                 }
               ]
             },
-            "priority": {
-              "anyOf": [
-                {
-                  "$ref": "#/$defs/PriorityConfig"
-                },
-                {
-                  "type": "null"
-                }
-              ],
-              "description": "Optional. Custom run priority config, including the path to your Python priority logic.\n\nAllows you to decide each thread's priority settings at the first run on a thread with no settings,\nwhich can come long after the thread was created.\n"
-            },
             "source": {
               "$ref": "#/$defs/UvSource"
             },
@@ -688,17 +666,6 @@
                 }
               ]
             },
-            "priority": {
-              "anyOf": [
-                {
-                  "$ref": "#/$defs/PriorityConfig"
-                },
-                {
-                  "type": "null"
-                }
-              ],
-              "description": "Optional. Custom run priority config, including the path to your Python priority logic.\n\nAllows you to decide each thread's priority settings at the first run on a thread with no settings,\nwhich can come long after the thread was created.\n"
-            },
             "source": {
               "anyOf": [
                 {
@@ -1203,18 +1170,6 @@
       },
       "required": []
     },
-    "PriorityConfig": {
-      "title": "PriorityConfig",
-      "description": "Configuration for custom run priority logic.\n\nAllows you to decide each thread's priority settings with a Python function\nthat the server calls at the first run on a thread with no settings, which\ncan come long after the thread was created.",
-      "type": "object",
-      "properties": {
-        "path": {
-          "type": "string",
-          "description": "Required. Path to an instance of the Priority() class that registers an assign function.\n"
-        }
-      },
-      "required": []
-    },
     "UvSource": {
       "title": "UvSource",
       "description": "Deployment source rooted at a uv project or workspace.",

libs/cli/tests/unit_tests/cli/test_cli.py

@@ -2,12 +2,10 @@ import json
 import pathlib
 import re
 import shutil
-import sys
 import tempfile
 import textwrap
 from contextlib import contextmanager
 from pathlib import Path
-from unittest.mock import MagicMock
 
 import click
 from click.testing import CliRunner
@@ -373,32 +371,6 @@ def test_dev_command_requires_ssl_certfile_and_keyfile_together(tmp_path) -> Non
     assert "Both --ssl-certfile and --ssl-keyfile must be provided" in result.output
 
 
-def test_dev_command_passes_priority_to_the_server(tmp_path, monkeypatch) -> None:
-    config_path = tmp_path / "langgraph.json"
-    config_path.write_text(
-        json.dumps(
-            {
-                "dependencies": ["."],
-                "graphs": {"agent": "./agent.py:graph"},
-                "priority": {"path": "./priority.py:priority"},
-            }
-        ),
-        encoding="utf-8",
-    )
-    # The test environment doesn't install langgraph-api, so stand in for its server.
-    server = MagicMock()
-    monkeypatch.setitem(sys.modules, "langgraph_api.cli", server)
-    # dev appends the working directory and its dependencies to sys.path.
-    monkeypatch.setattr(sys, "path", list(sys.path))
-
-    result = CliRunner().invoke(cli, ["dev", "--config", str(config_path)])
-
-    assert result.exit_code == 0, result.output
-    assert server.run_server.call_args.kwargs["priority"] == {
-        "path": "./priority.py:priority"
-    }
-
-
 def test_deploy_list_command(monkeypatch) -> None:
     runner = CliRunner()
     captured: dict[str, str] = {}
@@ -482,6 +454,177 @@ def test_deploy_list_command_no_results(monkeypatch) -> None:
     assert result.output.strip() == "No deployments found."
 
 
+def test_deploy_list_prints_an_aligned_table(monkeypatch) -> None:
+    class FakeClient:
+        def __init__(self, host_url: str, api_key: str, tenant_id: str | None = None):
+            pass
+
+        def list_deployments(self, name_contains: str = ""):
+            return [
+                {
+                    "id": "dep-123",
+                    "name": "alpha",
+                    "source_config": {"custom_url": "https://alpha.example.com"},
+                },
+                {"id": "dep-4567", "name": "beta-agent", "source_config": {}},
+            ]
+
+    monkeypatch.setattr(deploy_module, "HostBackendClient", FakeClient)
+
+    result = CliRunner().invoke(
+        cli,
+        [
+            "deploy",
+            "list",
+            "--api-key",
+            "test-key",
+            "--host-url",
+            "https://api.example.com",
+        ],
+    )
+
+    assert result.exit_code == 0, result.output
+    assert result.output.splitlines() == [
+        "Deployment ID  Deployment Name  Deployment URL           ",
+        "-------------  ---------------  -------------------------",
+        "dep-123        alpha            https://alpha.example.com",
+        "dep-4567       beta-agent       -                        ",
+    ]
+
+
+def _deploy_list_json(
+    monkeypatch, deployments: list[dict], *extra_args: str
+) -> click.testing.Result:
+    class FakeClient:
+        def __init__(self, host_url: str, api_key: str, tenant_id: str | None = None):
+            pass
+
+        def list_deployments(
+            self,
+            name_contains: str = "",
+            agent_id: str | None = None,
+            agent_environment: str | None = None,
+        ):
+            return deployments
+
+    monkeypatch.setattr(deploy_module, "HostBackendClient", FakeClient)
+    return CliRunner().invoke(
+        cli,
+        [
+            "deploy",
+            "list",
+            "--json",
+            "--api-key",
+            "test-key",
+            "--host-url",
+            "https://api.example.com",
+            *extra_args,
+        ],
+    )
+
+
+def test_deploy_list_command_json(monkeypatch) -> None:
+    result = _deploy_list_json(
+        monkeypatch,
+        [
+            {
+                "id": "dep-123",
+                "name": "alpha",
+                "source_config": {"custom_url": "https://alpha.example.com"},
+            },
+            {"id": "dep-456", "name": "beta", "source_config": {}},
+        ],
+    )
+
+    assert result.exit_code == 0, result.output
+    assert json.loads(result.stdout) == [
+        {"id": "dep-123", "name": "alpha"},
+        {"id": "dep-456", "name": "beta"},
+    ]
+
+
+def test_deploy_list_json_never_prints_deployment_secrets(monkeypatch) -> None:
+    result = _deploy_list_json(
+        monkeypatch,
+        [
+            {
+                "id": "dep-123",
+                "name": "alpha",
+                "source_config": {"custom_url": None},
+                "secrets": [{"name": "OPENAI_API_KEY", "value": "sk-plain-value"}],
+            }
+        ],
+    )
+
+    assert result.exit_code == 0, result.output
+    assert "sk-plain-value" not in result.output
+    assert json.loads(result.stdout) == [{"id": "dep-123", "name": "alpha"}]
+
+
+def test_deploy_list_command_json_no_results(monkeypatch) -> None:
+    result = _deploy_list_json(monkeypatch, [])
+
+    assert result.exit_code == 0, result.output
+    assert json.loads(result.stdout) == []
+
+
+def test_deploy_list_rejects_a_deployment_without_an_id(monkeypatch) -> None:
+    result = _deploy_list_json(monkeypatch, [{"name": "alpha"}])
+
+    assert result.exit_code != 0
+    assert "deployment without an id" in result.output
+
+
+def test_deploy_list_json_keeps_the_agent_note_off_stdout(monkeypatch) -> None:
+    result = _deploy_list_json(
+        monkeypatch,
+        [{"id": "dep-123", "name": "alpha"}],
+        "--agent-id",
+        "customer-support",
+        "--agent-environment",
+        "staging",
+    )
+
+    assert result.exit_code == 0, result.output
+    assert json.loads(result.stdout) == [{"id": "dep-123", "name": "alpha"}]
+    assert "private beta" in result.stderr
+
+
+def test_deploy_list_json_never_prompts_for_a_workspace(monkeypatch) -> None:
+    class FakeClient:
+        def __init__(self, host_url: str, api_key: str, tenant_id: str | None = None):
+            pass
+
+        def list_deployments(self, name_contains: str = ""):
+            raise HostBackendError("requires workspace specification", status_code=403)
+
+        def set_tenant(self, tenant_id: str) -> None:
+            raise AssertionError("must not retry with a prompted tenant with --json")
+
+    monkeypatch.setattr(deploy_module, "HostBackendClient", FakeClient)
+    prompt_calls = []
+    monkeypatch.setattr(
+        click, "prompt", lambda *a, **k: prompt_calls.append((a, k)) or "unreachable"
+    )
+
+    result = CliRunner().invoke(
+        cli,
+        [
+            "deploy",
+            "list",
+            "--json",
+            "--api-key",
+            "test-key",
+            "--host-url",
+            "https://api.example.com",
+        ],
+    )
+
+    assert prompt_calls == []
+    assert result.exit_code != 0
+    assert "LANGSMITH_TENANT_ID" in result.output
+
+
 def test_deploy_listeners_list_command(monkeypatch) -> None:
     runner = CliRunner()
     captured: dict[str, str] = {}
@@ -564,6 +707,84 @@ def test_deploy_listeners_list_command_no_results(monkeypatch) -> None:
     assert result.output.strip() == "No listeners found for this workspace."
 
 
+def test_deploy_listeners_list_prints_an_aligned_table(monkeypatch) -> None:
+    class FakeClient:
+        def __init__(self, host_url: str, api_key: str, tenant_id: str | None = None):
+            pass
+
+        def list_listeners(self):
+            return [
+                {
+                    "id": "listener-1",
+                    "compute_id": "prod-cluster",
+                    "compute_config": {"k8s_namespaces": ["agents"]},
+                },
+                {
+                    "id": "listener-22",
+                    "compute_id": "multi",
+                    "compute_config": {"k8s_namespaces": ["agents", "agents-staging"]},
+                },
+                {"id": "listener-3", "compute_id": "", "compute_config": {}},
+                {
+                    "id": "listener-4",
+                    "compute_id": None,
+                    "compute_config": {"k8s_namespaces": ["agents"]},
+                },
+            ]
+
+    monkeypatch.setattr(deploy_module, "HostBackendClient", FakeClient)
+
+    result = CliRunner().invoke(
+        cli,
+        [
+            "deploy",
+            "listeners",
+            "list",
+            "--api-key",
+            "test-key",
+            "--host-url",
+            "https://api.example.com",
+        ],
+    )
+
+    assert result.exit_code == 0, result.output
+    assert result.output.splitlines() == [
+        "Listener ID  Compute ID    Namespaces            ",
+        "-----------  ------------  ----------------------",
+        "listener-1   prod-cluster  agents                ",
+        "listener-22  multi         agents, agents-staging",
+        "listener-3   -             -                     ",
+        "listener-4   -             agents                ",
+    ]
+
+
+def test_deploy_listeners_list_rejects_a_listener_without_an_id(monkeypatch) -> None:
+    class FakeClient:
+        def __init__(self, host_url: str, api_key: str, tenant_id: str | None = None):
+            pass
+
+        def list_listeners(self):
+            return [{"compute_id": "prod-cluster"}]
+
+    monkeypatch.setattr(deploy_module, "HostBackendClient", FakeClient)
+
+    result = CliRunner().invoke(
+        cli,
+        [
+            "deploy",
+            "listeners",
+            "list",
+            "--api-key",
+            "test-key",
+            "--host-url",
+            "https://api.example.com",
+        ],
+    )
+
+    assert result.exit_code != 0
+    assert "listener without an id" in result.output
+
+
 def test_deploy_listeners_list_command_json(monkeypatch) -> None:
     runner = CliRunner()
 
@@ -766,6 +987,54 @@ def test_deploy_revisions_list_command_no_results(monkeypatch) -> None:
     assert result.output.strip() == "No revisions found for deployment dep-123."
 
 
+def test_deploy_revisions_list_marks_older_deployed_revisions_as_replaced(
+    monkeypatch,
+) -> None:
+    class FakeClient:
+        def __init__(self, host_url: str, api_key: str, tenant_id: str | None = None):
+            pass
+
+        def list_revisions(self, deployment_id: str, limit: int = 1):
+            return [
+                {
+                    "id": "rev-3",
+                    "status": "DEPLOYING",
+                    "created_at": "2026-10-20T10:00:00Z",
+                },
+                {
+                    "id": "rev-2",
+                    "status": "DEPLOYED",
+                    "created_at": "2026-10-19T10:00:00Z",
+                },
+                {"id": "rev-1", "status": "DEPLOYED", "created_at": None},
+            ]
+
+    monkeypatch.setattr(deploy_module, "HostBackendClient", FakeClient)
+
+    result = CliRunner().invoke(
+        cli,
+        [
+            "deploy",
+            "revisions",
+            "list",
+            "--api-key",
+            "test-key",
+            "--host-url",
+            "https://api.example.com",
+            "dep-123",
+        ],
+    )
+
+    assert result.exit_code == 0, result.output
+    assert result.output.splitlines() == [
+        "Revision ID  Status     Created At          ",
+        "-----------  ---------  --------------------",
+        "rev-3        DEPLOYING  2026-10-20T10:00:00Z",
+        "rev-2        DEPLOYED   2026-10-19T10:00:00Z",
+        "rev-1        REPLACED   -                   ",
+    ]
+
+
 def test_deploy_revisions_list_command_with_explicit_limit(monkeypatch) -> None:
     runner = CliRunner()
     captured: dict[str, str] = {}

libs/cli/tests/unit_tests/cli/test_deploy_command.py

@@ -111,7 +111,11 @@ class ControlPlaneDouble:
     def _respond(self, request: httpx.Request) -> httpx.Response:
         method, path = request.method, request.url.path
         if (method, path) == ("GET", "/v2/listeners"):
-            return httpx.Response(200, json={"resources": self.listeners})
+            offset = int(request.url.params.get("offset", 0))
+            limit = int(request.url.params.get("limit", 20))
+            return httpx.Response(
+                200, json={"resources": self.listeners[offset : offset + limit]}
+            )
         if method == "GET" and path.startswith("/v2/listeners/"):
             listener_id = path.rsplit("/", 1)[-1]
             if not _looks_like_a_uuid(listener_id):
@@ -1288,14 +1292,16 @@ def test_listener_flags_without_push_to_make_no_call_at_all(
     assert deploy_project.timeline == []
 
 
-def test_a_truncated_listener_page_says_so(deploy_project: DeployProject) -> None:
+def test_listeners_beyond_the_first_page_are_counted(
+    deploy_project: DeployProject,
+) -> None:
     deploy_project.control_plane.listeners = [
         {
             "id": str(uuid.UUID(int=index)),
             "compute_id": "cluster",
             "compute_config": {"k8s_namespaces": ["agents"]},
         }
-        for index in range(100)
+        for index in range(101)
     ]
 
     result = deploy_project.run(
@@ -1303,7 +1309,8 @@ def test_a_truncated_listener_page_says_so(deploy_project: DeployProject) -> Non
     )
 
     assert result.exit_code != 0
-    assert "first 100" in result.output
+    assert "... and 91 more" in result.output
+    assert "first 100" not in result.output
 
 
 def test_a_managed_build_in_a_listener_workspace_points_at_push_to(

libs/cli/tests/unit_tests/test_config.py

@@ -16,7 +16,6 @@ from langgraph_cli.config import (
     config_to_docker,
     default_base_image,
     docker_tag,
-    get_unknown_keys,
     has_disallowed_build_command_content,
     validate_config,
     validate_config_file,
@@ -156,7 +155,6 @@ def test_validate_config():
         "store": None,
         "auth": None,
         "encryption": None,
-        "priority": None,
         "webhooks": None,
         "checkpointer": None,
         "http": None,
@@ -186,7 +184,6 @@ def test_validate_config():
         "store": None,
         "auth": None,
         "encryption": None,
-        "priority": None,
         "webhooks": None,
         "checkpointer": None,
         "http": None,
@@ -1292,109 +1289,6 @@ def test_config_to_docker_python_encryption_formatted():
     )
 
 
-@pytest.mark.parametrize(
-    "path", ["./priority.py:priority", "my_package.priority:priority"]
-)
-def test_config_to_docker_python_priority(path: str):
-    # Test that priority config is kept by validation and isn't an unknown key
-    raw_config = {
-        "python_version": "3.11",
-        "graphs": {"agent": "./agent.py:graph"},
-        "dependencies": ["."],
-        "priority": {"path": path},
-    }
-    validated = validate_config(raw_config)
-
-    assert validated["priority"] == {"path": path}
-    assert get_unknown_keys(raw_config) == []
-
-
-def test_config_to_docker_python_priority_bad_path():
-    # Test that invalid priority path format raises ValueError
-    with pytest.raises(ValueError, match="Invalid priority.path format"):
-        validate_config(
-            {
-                "python_version": "3.11",
-                "graphs": {"agent": "./agent.py:graph"},
-                "dependencies": ["."],
-                "priority": {"path": "./priority.py"},  # Missing :attribute
-            }
-        )
-
-
-@pytest.mark.parametrize("ext", [".ts", ".mts", ".cts", ".js", ".mjs", ".cjs"])
-def test_config_to_docker_python_priority_js_path(ext: str):
-    # Test that a JavaScript priority path is rejected
-    with pytest.raises(ValueError, match="JavaScript priority callbacks"):
-        validate_config(
-            {
-                "python_version": "3.11",
-                "graphs": {"agent": "./agent.py:graph"},
-                "dependencies": ["."],
-                "priority": {"path": f"./priority{ext}:priority"},
-            }
-        )
-
-
-def test_config_to_docker_nodejs_priority():
-    # Test that a Node.js-only project can name a Python priority file
-    actual_docker_stdin, _ = config_to_docker(
-        PATH_TO_CONFIG,
-        validate_config(
-            {
-                "node_version": "20",
-                "graphs": {"agent": "./graphs/agent.js:graph"},
-                "priority": {"path": "./priority.py:priority"},
-            }
-        ),
-        base_image="langchain/langgraphjs-api",
-    )
-    assert (
-        """ENV LANGGRAPH_PRIORITY='{"path": "./priority.py:priority"}'"""
-        in actual_docker_stdin
-    )
-
-
-def test_config_to_docker_python_priority_formatted():
-    # Test that priority config is written to the Docker output with its container path
-    actual_docker_stdin, _ = config_to_docker(
-        PATH_TO_CONFIG,
-        validate_config(
-            {
-                "python_version": "3.11",
-                "dependencies": ["."],
-                "graphs": {"agent": "./graphs/agent.py:graph"},
-                "priority": {"path": "./agent.py:my_priority"},
-            }
-        ),
-        base_image="langchain/langgraph-api",
-    )
-    assert (
-        "ENV LANGGRAPH_PRIORITY="
-        """'{"path": "/deps/outer-unit_tests/unit_tests/agent.py:my_priority"}'"""
-        in actual_docker_stdin
-    )
-
-
-def test_config_to_docker_python_priority_not_in_dependencies():
-    # Test that a priority file outside the dependencies raises ValueError
-    with pytest.raises(
-        ValueError, match="Priority file .* not covered by dependencies"
-    ):
-        config_to_docker(
-            PATH_TO_CONFIG,
-            validate_config(
-                {
-                    "python_version": "3.11",
-                    "dependencies": ["./graphs"],
-                    "graphs": {"agent": "./graphs/agent.py:graph"},
-                    "priority": {"path": "./agent.py:my_priority"},
-                }
-            ),
-            base_image="langchain/langgraph-api",
-        )
-
-
 def test_config_to_docker_nodejs_internal_docker_tag():
     graphs = {"agent": "./graphs/agent.js:graph"}
     actual_docker_stdin, additional_contexts = config_to_docker(
@@ -1837,38 +1731,6 @@ def test_config_to_docker_uv_lock_honors_root_workspace_sources():
         )
 
 
-def test_config_to_docker_uv_lock_rewrites_priority_path():
-    with tempfile.TemporaryDirectory() as tmpdir:
-        tmpdir_path = pathlib.Path(tmpdir)
-        project_root, config_path = _write_uv_lock_workspace(
-            tmpdir_path,
-            agent_sources="[tool.uv.sources]\nshared = { workspace = true }",
-        )
-        (project_root / "libs" / "shared" / "src" / "shared" / "priority.py").touch()
-
-        config = validate_config(
-            {
-                "python_version": "3.11",
-                "graphs": {
-                    "agent": "../../apps/agent/src/agent/graph.py:graph",
-                },
-                "source": {"kind": "uv", "root": "../..", "package": "agent"},
-                "priority": {
-                    "path": "../../libs/shared/src/shared/priority.py:priority"
-                },
-            }
-        )
-        docker, _ = config_to_docker(
-            config_path, config, base_image="langchain/langgraph-api:0.2.47"
-        )
-
-        assert (
-            "ENV LANGGRAPH_PRIORITY="
-            """'{"path": "/deps/workspace/libs/shared/src/shared/priority.py:priority"}'"""
-            in docker
-        )
-
-
 def test_config_to_docker_uv_lock_ignores_unrelated_workspace_package_sources():
     with tempfile.TemporaryDirectory() as tmpdir:
         tmpdir_path = pathlib.Path(tmpdir)

libs/cli/tests/unit_tests/test_deploy_agents.py

@@ -75,6 +75,7 @@ def test_agent_create(deployment_api, tmp_path, monkeypatch):
         "agent_id": "customer-support",
         "agent_environment": "staging",
         "limit": "100",
+        "offset": "0",
     }
     payload = json.loads(requests[1].content)
     assert payload["agent"] == {

libs/cli/tests/unit_tests/test_deploy_helpers.py

@@ -33,6 +33,7 @@ from langgraph_cli.deploy import (
     _Emitter,
     _env_without_deployment_name,
     _parse_env_from_config,
+    _print_deployment_result,
     _resolve_env_path,
     _resolve_pushed_image_digest,
     _resource_spec,
@@ -536,6 +537,39 @@ class TestEmitterTextMode:
         assert "URL: https://app.test" in lines
 
 
+@pytest.mark.parametrize(
+    ("deployment", "expected_url_lines"),
+    [
+        pytest.param(
+            {
+                "id": "dep-1",
+                "source_config": {"custom_url": "https://agent.example.com"},
+            },
+            ["URL: https://agent.example.com"],
+            id="custom_url_is_printed",
+        ),
+        pytest.param(
+            {"id": "dep-1", "source_config": {}}, [], id="no_custom_url_no_line"
+        ),
+    ],
+)
+def test_a_deployed_result_prints_the_deployment_url(
+    capsys, monkeypatch, deployment, expected_url_lines
+):
+    class FakeClient:
+        def get_deployment(self, deployment_id: str) -> dict:
+            return deployment
+
+    monkeypatch.setattr(deploy_mod, "_emitter", None)
+
+    _print_deployment_result(
+        FakeClient(), "dep-1", "DEPLOYED", dashboard_label="Deployment dashboard"
+    )
+
+    lines = [line.strip() for line in capsys.readouterr().out.splitlines()]
+    assert [line for line in lines if line.startswith("URL:")] == expected_url_lines
+
+
 # ---------------------------------------------------------------------------
 # --no-input guard on _create_host_backend_client
 # ---------------------------------------------------------------------------
@@ -1210,6 +1244,7 @@ def test_finding_a_deployment_by_name_narrows_the_search_for_every_server_versio
         "name": "agent",
         "name_contains": "agent",
         "limit": "100",
+        "offset": "0",
     }
     assert found == ExistingDeployment("dep-1", "github")
 
@@ -1237,20 +1272,29 @@ def test_a_server_that_ignores_the_exact_name_filter_never_matches_another_deplo
     assert find_deployment_by_name(client, "brand-new-agent") is None
 
 
-def test_a_full_page_without_a_match_refuses_to_claim_the_name_is_free():
-    page = [
-        {"id": f"dep-{index}", "name": f"other-agent-{index}"} for index in range(100)
-    ]
-    client = HostBackendClient(
-        "https://api.example.com",
-        "key",
-        transport=httpx.MockTransport(
-            lambda req: httpx.Response(200, json={"resources": page})
+def test_a_deployment_beyond_the_first_page_is_found_by_name():
+    deployments = [
+        *(
+            {"id": f"dep-{index}", "name": f"other-agent-{index}"}
+            for index in range(100)
         ),
+        {"id": "dep-target", "name": "agent", "source": "external_docker"},
+    ]
+
+    def handler(req: httpx.Request) -> httpx.Response:
+        offset = int(req.url.params["offset"])
+        limit = int(req.url.params["limit"])
+        return httpx.Response(
+            200, json={"resources": deployments[offset : offset + limit]}
+        )
+
+    client = HostBackendClient(
+        "https://api.example.com", "key", transport=httpx.MockTransport(handler)
     )
 
-    with pytest.raises(click.ClickException, match="--deployment-id"):
-        find_deployment_by_name(client, "brand-new-agent")
+    assert find_deployment_by_name(client, "agent") == ExistingDeployment(
+        "dep-target", "external_docker"
+    )
 
 
 def test_a_partial_page_without_a_match_means_the_name_is_free():

libs/cli/tests/unit_tests/test_host_backend.py

@@ -575,7 +575,7 @@ def test_list_listeners_asks_for_a_full_page():
     )
 
     assert c.list_listeners() == [{"id": "listener-1"}]
-    assert seen["url"] == "https://api.example.com/v2/listeners?limit=100"
+    assert seen["url"] == "https://api.example.com/v2/listeners?limit=100&offset=0"
 
 
 @pytest.mark.parametrize(
@@ -602,29 +602,30 @@ def test_is_cloud_recognises_the_managed_control_plane(control_plane_url, expect
     assert endpoints.is_cloud is expected
 
 
+FIRST_PAGE = {"limit": "100", "offset": "0"}
+
+
 @pytest.mark.parametrize(
     ("call", "expected_params"),
     [
         pytest.param(
             lambda c: c.list_deployments(name="agent"),
-            {"name": "agent"},
+            {"name": "agent", **FIRST_PAGE},
             id="exact_name_filters_server_side",
         ),
         pytest.param(
             lambda c: c.list_deployments(name_contains="age"),
-            {"name_contains": "age"},
+            {"name_contains": "age", **FIRST_PAGE},
             id="substring_search_keeps_its_own_parameter",
         ),
         pytest.param(
             lambda c: c.list_deployments(),
-            {},
-            id="no_filter_sends_no_parameters",
+            FIRST_PAGE,
+            id="no_filter_sends_only_the_page",
         ),
         pytest.param(
-            lambda c: c.list_deployments(
-                name="agent", name_contains="agent", limit=100
-            ),
-            {"name": "agent", "name_contains": "agent", "limit": "100"},
+            lambda c: c.list_deployments(name="agent", name_contains="agent"),
+            {"name": "agent", "name_contains": "agent", **FIRST_PAGE},
             id="both_filters_travel_together_for_older_servers",
         ),
     ],
@@ -645,6 +646,68 @@ def test_list_deployments_sends_one_name_filter(call, expected_params):
     assert seen == expected_params
 
 
+@pytest.mark.parametrize(
+    "list_every",
+    [
+        pytest.param(HostBackendClient.list_deployments, id="deployments"),
+        pytest.param(HostBackendClient.list_listeners, id="listeners"),
+    ],
+)
+def test_list_endpoints_read_every_page(list_every):
+    resources = [{"id": f"resource-{index}"} for index in range(101)]
+    offsets: list[str] = []
+
+    def handler(req: httpx.Request) -> httpx.Response:
+        offset = int(req.url.params["offset"])
+        limit = int(req.url.params["limit"])
+        offsets.append(req.url.params["offset"])
+        return httpx.Response(
+            200, json={"resources": resources[offset : offset + limit]}
+        )
+
+    c = HostBackendClient(
+        "https://api.example.com", "key", transport=httpx.MockTransport(handler)
+    )
+
+    assert list_every(c) == resources
+    assert offsets == ["0", "100"]
+
+
+FIRST_PAGE_OF_DEPLOYMENTS = [
+    {"id": f"dep-{index}", "status": "DEPLOYED"} for index in range(100)
+]
+
+
+@pytest.mark.parametrize(
+    "repeated_page",
+    [
+        pytest.param(FIRST_PAGE_OF_DEPLOYMENTS, id="same_page_again"),
+        pytest.param(
+            [
+                {"id": "dep-99", "status": "DEPLOYING"},
+                *FIRST_PAGE_OF_DEPLOYMENTS[:99],
+            ],
+            id="same_deployments_reordered_and_updated",
+        ),
+    ],
+)
+def test_list_deployments_fails_when_the_server_ignores_the_offset(repeated_page):
+    pages = iter([FIRST_PAGE_OF_DEPLOYMENTS, repeated_page])
+
+    def handler(req: httpx.Request) -> httpx.Response:
+        page = next(pages, None)
+        if page is None:
+            return httpx.Response(500, json={"detail": "the guard let paging run on"})
+        return httpx.Response(200, json={"resources": page})
+
+    c = HostBackendClient(
+        "https://api.example.com", "key", transport=httpx.MockTransport(handler)
+    )
+
+    with pytest.raises(HostBackendError, match="ignores 'offset'"):
+        c.list_deployments()
+
+
 @pytest.mark.parametrize(
     ("body", "expected"),
     [

libs/cli/tests/unit_tests/test_util.py

@@ -1,11 +1,6 @@
 from unittest.mock import patch
 
-from langgraph_cli.deploy import (
-    _extract_deployment_url,
-    format_deployments_table,
-    format_listeners_table,
-    format_revisions_table,
-)
+from langgraph_cli.deploy import Table
 from langgraph_cli.util import clean_empty_lines, warn_non_wolfi_distro
 
 
@@ -194,96 +189,7 @@ def test_warn_non_wolfi_distro_does_not_modify_config():
     assert config_copy == original_config  # Config should remain unchanged
 
 
-def test_extract_deployment_url_uses_custom_url():
-    deployment = {"source_config": {"custom_url": "https://example.com/custom"}}
-    assert _extract_deployment_url(deployment) == "https://example.com/custom"
+def test_a_table_without_rows_still_renders_its_headers():
+    table = Table(("Name", "Status"), lambda resource: (None, None))
 
-
-def test_extract_deployment_url_defaults_to_dash():
-    assert _extract_deployment_url({"id": "dep-123"}) == "-"
-
-
-def test_format_deployments_table():
-    output = format_deployments_table(
-        [
-            {
-                "id": "dep-123",
-                "name": "alpha",
-                "source_config": {"custom_url": "https://alpha.example.com"},
-            },
-            {
-                "id": "dep-456",
-                "name": "beta",
-                "url": "https://beta.example.com",
-            },
-        ]
-    )
-    assert "Deployment ID" in output
-    assert "Deployment Name" in output
-    assert "Deployment URL" in output
-    assert "dep-123" in output
-    assert "alpha" in output
-    assert "https://alpha.example.com" in output
-    assert "dep-456" in output
-
-
-def test_format_revisions_table():
-    output = format_revisions_table(
-        [
-            {
-                "id": "rev-123",
-                "status": "DEPLOYED",
-                "created_at": "2023-11-09T10:00:00Z",
-            },
-            {
-                "id": "rev-456",
-                "status": "CREATING",
-                "created_at": "2023-11-07T05:31:56Z",
-            },
-            {
-                "id": "rev-789",
-                "status": "DEPLOYED",
-                "created_at": "2023-11-08T10:00:00Z",
-            },
-        ]
-    )
-    assert "Revision ID" in output
-    assert "Status" in output
-    assert "Created At" in output
-    assert "rev-123" in output
-    assert "CREATING" in output
-    assert "2023-11-07T05:31:56Z" in output
-    assert "rev-456" in output
-    assert "rev-789" in output
-    assert "REPLACED" in output
-
-
-def test_format_listeners_table():
-    output = format_listeners_table(
-        [
-            {
-                "id": "listener-1",
-                "compute_id": "prod-cluster",
-                "compute_config": {"k8s_namespaces": ["agents"]},
-            },
-            {
-                "id": "listener-2",
-                "compute_id": "multi-cluster",
-                "compute_config": {"k8s_namespaces": ["agents", "agents-staging"]},
-            },
-            {
-                "id": "listener-3",
-                "compute_id": "broken-cluster",
-            },
-        ]
-    )
-    assert "Listener ID" in output
-    assert "Compute ID" in output
-    assert "Namespaces" in output
-    assert "listener-1" in output
-    assert "prod-cluster" in output
-    assert "agents" in output
-    assert "listener-2" in output
-    assert "agents, agents-staging" in output
-    assert "listener-3" in output
-    assert "broken-cluster" in output
+    assert table.render([]).splitlines() == ["Name  Status", "----  ------"]

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

@@ -1,5 +1,5 @@
 version = 1
-revision = 5
+revision = 3
 requires-python = ">=3.11"
 
 [manifest]
@@ -267,20 +267,20 @@ wheels = [
 
 [[package]]
 name = "langgraph-checkpoint"
-version = "4.3.0"
+version = "4.2.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "langchain-core" },
     { name = "ormsgpack" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/0f/69/31fdbdc65a85bbd6178afa193c772bb926620f47b4869638bc2bc80afaaa/langgraph_checkpoint-4.3.0.tar.gz", hash = "sha256:c75965d84cc2c1d549163e910a15bcb577758001b141619d05297c463280b018", size = 182652, upload-time = "2026-10-12T22:26:31.478Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/dc/e1/089c4c9e0a2fec7f883f82ae8e6a727138d50074cfeb6644bc2d13b1019b/langgraph_checkpoint-4.2.0.tar.gz", hash = "sha256:51a593b6bee684b0818e5d6e58e28ab340c6db7794575056ce7bd1b746a84ed7", size = 180239, upload-time = "2026-08-07T20:05:03.756Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/1f/0c/84747e340bf4f29291c84cdd5733fc8d0a822f3d33bb24e664a18afa4a7c/langgraph_checkpoint-4.3.0-py3-none-any.whl", hash = "sha256:bedfafe2f997ded60e4fa593e79f56f436a6e45586392dc382aa810d0c751c64", size = 58063, upload-time = "2026-10-12T22:26:30.429Z" },
+    { url = "https://files.pythonhosted.org/packages/05/71/3b475f09bd57d3a5649792c66353312b4432afd843f301739dfcebd157f0/langgraph_checkpoint-4.2.0-py3-none-any.whl", hash = "sha256:0547fd228935a0b758865de3a3d6d7a2537c308895d0f9ab092ce9151b5da942", size = 56833, upload-time = "2026-08-07T20:05:02.655Z" },
 ]
 
 [[package]]
 name = "langgraph-checkpoint-postgres"
-version = "3.1.3"
+version = "3.1.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "langgraph-checkpoint" },
@@ -288,9 +288,9 @@ dependencies = [
     { name = "psycopg" },
     { name = "psycopg-pool" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/78/bf/d0ab4d6e4d61952de2f77044d7407b7ce09e07d53e7bb448cf9df55c35e5/langgraph_checkpoint_postgres-3.1.3.tar.gz", hash = "sha256:a152a9c0c3d5931bc949b64e01e8c7da20be57a32aa754626446318e90a07650", size = 158122, upload-time = "2026-10-12T23:05:19.759Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/06/92/1e8959f8cd1b56e672fde3227f6fd642be85af6c5fd662d73921074aa39d/langgraph_checkpoint_postgres-3.1.1.tar.gz", hash = "sha256:d320e147ddad8c374cd546df0b52b532dd54d0541dd9fd23fc738cbd5de76f41", size = 150413, upload-time = "2026-07-30T19:15:39.014Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/41/42/659106ed829ee026144e32ddd589735f978d2ed09681020e5965cdfca04c/langgraph_checkpoint_postgres-3.1.3-py3-none-any.whl", hash = "sha256:050ae583223e24d97747f27b9e06e7345bf13c972f1fb6ed33bb3d1f9c11cee4", size = 52048, upload-time = "2026-10-12T23:05:18.854Z" },
+    { url = "https://files.pythonhosted.org/packages/03/32/ba457698a48a0e18d786caa770033067049fbe36d6846f8e50f13b594b51/langgraph_checkpoint_postgres-3.1.1-py3-none-any.whl", hash = "sha256:6e353aecd8150de144fef8e51a49076f58b7d6830d4cf51392b7ad4d79832ba7", size = 50778, upload-time = "2026-07-30T19:15:37.405Z" },
 ]
 
 [[package]]

libs/cli/uv.lock

@@ -1,10 +1,10 @@
 version = 1
-revision = 5
+revision = 3
 requires-python = ">=3.10"
 resolution-markers = [
     "python_full_version >= '3.15'",
     "python_full_version >= '3.12' and python_full_version < '3.15' and sys_platform == 'emscripten'",
-    "python_full_version == '3.11.*' or (python_full_version >= '3.12' and python_full_version < '3.15' and sys_platform != 'emscripten')",
+    "(python_full_version >= '3.11' and python_full_version < '3.15' and sys_platform != 'emscripten') or (python_full_version == '3.11.*' and sys_platform == 'emscripten')",
     "python_full_version < '3.11'",
 ]
 
@@ -24,8 +24,7 @@ source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "exceptiongroup", marker = "python_full_version < '3.11'" },
     { name = "idna" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.11' and python_full_version < '3.13'" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.11'" },
+    { 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" }
 wheels = [
@@ -417,7 +416,7 @@ version = "50.0.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "cffi", marker = "platform_python_implementation != 'PyPy'" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.11'" },
+    { name = "typing-extensions", marker = "python_full_version < '3.11'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/de/41/6cbdcf9142d00fe82836fbb51e503e58088575cf7a0fe1dbff6695bf0840/cryptography-50.0.0.tar.gz", hash = "sha256:eeac2acb5a20ed25e0ad6d1df9891a520b78b404266b6d11778f25d5d691a6c9", size = 880201, upload-time = "2026-07-31T14:25:10.11Z" }
 wheels = [
@@ -470,11 +469,11 @@ wheels = [
 
 [[package]]
 name = "distlib"
-version = "0.4.4"
+version = "0.4.0"
 source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/68/bc/d36966de7304047a1001a7559fbf266c464bb5d8cc85464536ef8c9bcc32/distlib-0.4.4.tar.gz", hash = "sha256:ca4175b4ac7f71223cc30ed7248c45d2b38c2439d8ee6e498ab67ed63cf3508d", size = 621304, upload-time = "2026-10-16T13:56:34.203Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/96/8e/709914eb2b5749865801041647dc7f4e6d00b549cfe88b65ca192995f07c/distlib-0.4.0.tar.gz", hash = "sha256:feec40075be03a04501a973d81f633735b4b69f98b05450592310c0f401a4e0d", size = 614605, upload-time = "2025-07-17T16:52:00.465Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/c1/2b/238f02a4927fa2e27aa995371d240a468b52e42eae44a678434aff736b38/distlib-0.4.4-py2.py3-none-any.whl", hash = "sha256:cf09d55b1e85a89576b036aeb71550bfd68320f3f21761ca329eadadad918638", size = 472099, upload-time = "2026-10-16T13:56:32.053Z" },
+    { url = "https://files.pythonhosted.org/packages/33/6b/e0547afaf41bf2c42e52430072fa5658766e3d65bd4b03a563d1b6336f57/distlib-0.4.0-py2.py3-none-any.whl", hash = "sha256:9659f7d87e46584a30b5780e43ac7a2143098441670ff0a49d5f9034c54a6c16", size = 469047, upload-time = "2025-07-17T16:51:58.613Z" },
 ]
 
 [[package]]
@@ -497,7 +496,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 = [
@@ -536,7 +535,7 @@ name = "grpcio"
 version = "1.80.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/b7/48/af6173dbca4454f4637a4678b67f52ca7e0c1ed7d5894d89d434fecede05/grpcio-1.80.0.tar.gz", hash = "sha256:29aca15edd0688c22ba01d7cc01cb000d72b2033f4a3c72a81a19b56fd143257", size = 12978905, upload-time = "2026-03-30T08:49:10.502Z" }
 wheels = [
@@ -812,8 +811,7 @@ dependencies = [
     { name = "httpx2-jsfetch", marker = "python_full_version >= '3.12' and sys_platform == 'emscripten'" },
     { name = "idna" },
     { name = "truststore", marker = "sys_platform != 'emscripten'" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.11' and python_full_version < '3.13'" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.11'" },
+    { name = "typing-extensions", marker = "python_full_version < '3.13'" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/7f/f8/579a8b51e42e38ee32647df9f08aa25643ae788e275cc625b199829c4671/httpx2-2.12.0.tar.gz", hash = "sha256:7631fe9887a8a2275f4a2540e053aa670fcc50742864a9ae7c66e609fdcf12cf", size = 100040, upload-time = "2026-08-18T13:22:09.086Z" }
 wheels = [
@@ -1002,7 +1000,7 @@ dependencies = [
     { name = "pydantic" },
     { name = "pyyaml" },
     { name = "tenacity" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
     { name = "uuid-utils" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/59/de/679a53472c25860837e32c0442c962fa86e95317a36460e2c9d5c91b17c2/langchain_core-1.4.0.tar.gz", hash = "sha256:1dc341eed802ed9c117c0df3923c991e5e9e226571e5725c194eeb5bd93d1a7f", size = 920260, upload-time = "2026-05-11T18:42:35.919Z" }
@@ -1015,7 +1013,7 @@ name = "langchain-protocol"
 version = "0.0.17"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/44/b3/4e2429876c7a35585618caa2b9f9089f7162a6b50562b614ad82ac11c17e/langchain_protocol-0.0.17.tar.gz", hash = "sha256:e7cbe58c205df4b4fd87dc6d5bb23f10e13b236d0e2e1b0b9d05bc2b648f3eea", size = 6026, upload-time = "2026-06-12T18:39:51.923Z" }
 wheels = [
@@ -1339,114 +1337,84 @@ wheels = [
 
 [[package]]
 name = "opentelemetry-api"
-version = "1.45.1"
+version = "1.41.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "importlib-metadata" },
+    { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/2e/02/6e0ae9cc61bd3169d401077b507b3ebc344745171e1051ab430be012dcd9/opentelemetry_api-1.45.1.tar.gz", hash = "sha256:aa38ed19bcc084ba42782a73255b3582283eced7ad6dddbd6695189e69adfb75", size = 72804, upload-time = "2026-10-06T17:32:58.133Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/47/8e/3778a7e87801d994869a9396b9fc2a289e5f9be91ff54a27d41eace494b0/opentelemetry_api-1.41.0.tar.gz", hash = "sha256:9421d911326ec12dee8bc933f7839090cad7a3f13fcfb0f9e82f8174dc003c09", size = 71416, upload-time = "2026-04-09T14:38:34.544Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/1e/41/f7dcf80b81ee8e71c1a2b59f14208bc723edbd89ed027a73b175abf6348e/opentelemetry_api-1.45.1-py3-none-any.whl", hash = "sha256:b31553efa588ae44bc306f863c785c5333a9ecc091248c6ee68b4b6c87fdedfb", size = 60256, upload-time = "2026-10-06T17:32:33.506Z" },
-]
-
-[[package]]
-name = "opentelemetry-exporter-http-transport"
-version = "0.66b1"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "opentelemetry-api" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/62/0c/e3ebdb4b507f66afcc905e6885a4946969bd75b45988492643356fbbdc63/opentelemetry_exporter_http_transport-0.66b1.tar.gz", hash = "sha256:443080203bf52586ce0b2ad901e8951c61833eab1aa539ae6f1f16fe9e8e7952", size = 11693, upload-time = "2026-10-06T17:32:59.65Z" }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/04/69/6af86ff66492b481c6a4c05dcfd68beb47ed8ba046440a26a2aac76b95c7/opentelemetry_exporter_http_transport-0.66b1-py3-none-any.whl", hash = "sha256:2f95404bdee7f9d2d529c7de56c7bd86d014d774d8fbf137810e0167f8a492bf", size = 12155, upload-time = "2026-10-06T17:32:35.454Z" },
-]
-
-[package.optional-dependencies]
-requests = [
-    { name = "requests" },
-]
-
-[[package]]
-name = "opentelemetry-exporter-otlp-common"
-version = "0.66b1"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "opentelemetry-sdk" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/cb/19/41de712173f43057e4532d42ece7d0c6d4210d353e5752433cb14987643f/opentelemetry_exporter_otlp_common-0.66b1.tar.gz", hash = "sha256:6b1403487a2185ac1feb45fd5546fdf8630ce71c36bcefaadf51e2130e9e23f9", size = 14325, upload-time = "2026-10-06T17:33:01.725Z" }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/fc/39/8c23d67665c762aa51840fa06f86e902e8f6f1693bc8d7e3d98cd6e2f753/opentelemetry_exporter_otlp_common-0.66b1-py3-none-any.whl", hash = "sha256:00ff8592c3a7cb729ff3fdc7ffa12372c243bdf2163e80c180994d0c7bd83ee9", size = 12385, upload-time = "2026-10-06T17:32:38.177Z" },
+    { url = "https://files.pythonhosted.org/packages/58/ee/99ab786653b3bda9c37ade7e24a7b607a1b1f696063172768417539d876d/opentelemetry_api-1.41.0-py3-none-any.whl", hash = "sha256:0e77c806e6a89c9e4f8d372034622f3e1418a11bdbe1c80a50b3d3397ad0fa4f", size = 69007, upload-time = "2026-04-09T14:38:11.833Z" },
 ]
 
 [[package]]
 name = "opentelemetry-exporter-otlp-proto-common"
-version = "1.45.1"
+version = "1.41.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "opentelemetry-proto" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/c1/8e/65e85e5137991a3c493b11682151d198638a5bc1dd4b4c5f67e013c57d7c/opentelemetry_exporter_otlp_proto_common-1.45.1.tar.gz", hash = "sha256:2e4adcc3a67bcf57804fc49514f0ef64974ca7590aa3491da389852b4a0628f6", size = 18873, upload-time = "2026-10-06T17:33:04.471Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/8c/28/e8eca94966fe9a1465f6094dc5ddc5398473682180279c94020bc23b4906/opentelemetry_exporter_otlp_proto_common-1.41.0.tar.gz", hash = "sha256:966bbce537e9edb166154779a7c4f8ab6b8654a03a28024aeaf1a3eacb07d6ee", size = 20411, upload-time = "2026-04-09T14:38:36.572Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/84/aa/92f225d353904e7f70b8b3e3c1b02db0cf56f744c2e83c581dc372e78873/opentelemetry_exporter_otlp_proto_common-1.45.1-py3-none-any.whl", hash = "sha256:2f446183ae7047b036226f1d846c41a834b0e8755ad13b51a51dd38952eb466c", size = 15393, upload-time = "2026-10-06T17:32:41.911Z" },
+    { url = "https://files.pythonhosted.org/packages/26/c4/78b9bf2d9c1d5e494f44932988d9d91c51a66b9a7b48adf99b62f7c65318/opentelemetry_exporter_otlp_proto_common-1.41.0-py3-none-any.whl", hash = "sha256:7a99177bf61f85f4f9ed2072f54d676364719c066f6d11f515acc6c745c7acf0", size = 18366, upload-time = "2026-04-09T14:38:15.135Z" },
 ]
 
 [[package]]
 name = "opentelemetry-exporter-otlp-proto-http"
-version = "1.45.1"
+version = "1.41.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "googleapis-common-protos" },
     { name = "opentelemetry-api" },
-    { name = "opentelemetry-exporter-http-transport", extra = ["requests"] },
-    { name = "opentelemetry-exporter-otlp-common" },
     { name = "opentelemetry-exporter-otlp-proto-common" },
     { name = "opentelemetry-proto" },
     { name = "opentelemetry-sdk" },
     { name = "requests" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/1b/17/26487707ea4caa97b17e6e4b5fa72133a53512ffa2f5cf7a49ef284b29cb/opentelemetry_exporter_otlp_proto_http-1.45.1.tar.gz", hash = "sha256:45c218405ce3fd879596924b1874bf9a8f6880206d61065c5a912c8e5c297fb7", size = 28839, upload-time = "2026-10-06T17:33:05.713Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/19/63/d9f43cd75f3fabb7e01148c89cfa9491fc18f6580a6764c554ff7c953c46/opentelemetry_exporter_otlp_proto_http-1.41.0.tar.gz", hash = "sha256:dcd6e0686f56277db4eecbadd5262124e8f2cc739cadbc3fae3d08a12c976cf5", size = 24139, upload-time = "2026-04-09T14:38:38.128Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/aa/1f/517eaa0187ba106a9da97160ce2add3a371812681dc440930b267f714e42/opentelemetry_exporter_otlp_proto_http-1.45.1-py3-none-any.whl", hash = "sha256:24a97cf3753c7fb52fad44a696e452ff371686339e2acf3309e2eda3d0230700", size = 22180, upload-time = "2026-10-06T17:32:43.946Z" },
+    { url = "https://files.pythonhosted.org/packages/64/b5/a214cd907eedc17699d1c2d602288ae17cb775526df04db3a3b3585329d2/opentelemetry_exporter_otlp_proto_http-1.41.0-py3-none-any.whl", hash = "sha256:a9c4ee69cce9c3f4d7ee736ad1b44e3c9654002c0816900abbafd9f3cf289751", size = 22673, upload-time = "2026-04-09T14:38:18.349Z" },
 ]
 
 [[package]]
 name = "opentelemetry-proto"
-version = "1.45.1"
+version = "1.41.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "protobuf" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/4b/7f/15f014fb195da6c2dbb6c71399b8e76824878718e94de6454038488eed28/opentelemetry_proto-1.45.1.tar.gz", hash = "sha256:79e0fb95e4616691a469439238aa9224d75779b3e108e895d1aa125ab29ca77c", size = 46488, upload-time = "2026-10-06T17:33:11.49Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/e0/d9/08e3dc6156878713e8c811682bc76151f5fe1a3cb7f3abda3966fd56e71e/opentelemetry_proto-1.41.0.tar.gz", hash = "sha256:95d2e576f9fb1800473a3e4cfcca054295d06bdb869fda4dc9f4f779dc68f7b6", size = 45669, upload-time = "2026-04-09T14:38:45.978Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/ab/9a/42ec8180a769516ae757e893b69736826efceac7332553915b4528a91c6d/opentelemetry_proto-1.45.1-py3-none-any.whl", hash = "sha256:f38e2a8413053c180cd3d2637fbb279673ec2f6a6e09c995aafa2f452c52b46e", size = 72488, upload-time = "2026-10-06T17:32:53.057Z" },
+    { url = "https://files.pythonhosted.org/packages/49/8c/65ef7a9383a363864772022e822b5d5c6988e6f9dabeebb9278f5b86ebc3/opentelemetry_proto-1.41.0-py3-none-any.whl", hash = "sha256:b970ab537309f9eed296be482c3e7cca05d8aca8165346e929f658dbe153b247", size = 72074, upload-time = "2026-04-09T14:38:29.38Z" },
 ]
 
 [[package]]
 name = "opentelemetry-sdk"
-version = "1.45.1"
+version = "1.41.0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "opentelemetry-api" },
     { name = "opentelemetry-semantic-conventions" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/a1/79/7392e21a1c8f0c61d90b223e31c7e48cb9d452e91a6b820ad24cca5f23c4/opentelemetry_sdk-1.45.1.tar.gz", hash = "sha256:63d24a6ca645019a631e6a51999c73e93adcac1196ca640b8ae78a7cc4762bf3", size = 218324, upload-time = "2026-10-06T17:33:13.26Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/f8/0e/a586df1186f9f56b5a0879d52653effc40357b8e88fc50fe300038c3c08b/opentelemetry_sdk-1.41.0.tar.gz", hash = "sha256:7bddf3961131b318fc2d158947971a8e37e38b1cd23470cfb72b624e7cc108bd", size = 230181, upload-time = "2026-04-09T14:38:47.225Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/95/3c/87c42b4bd6dd297536f04cd9383d212ac557ecd49f2cbdcd46da1c9ef5c8/opentelemetry_sdk-1.45.1-py3-none-any.whl", hash = "sha256:c604c11dc429810812348989115fa44bd558772a3d7442afc43d024f2c250ca4", size = 140063, upload-time = "2026-10-06T17:32:55.04Z" },
+    { url = "https://files.pythonhosted.org/packages/2c/13/a7825118208cb32e6a4edcd0a99f925cbef81e77b3b0aedfd9125583c543/opentelemetry_sdk-1.41.0-py3-none-any.whl", hash = "sha256:a596f5687964a3e0d7f8edfdcf5b79cbca9c93c7025ebf5fb00f398a9443b0bd", size = 180214, upload-time = "2026-04-09T14:38:30.657Z" },
 ]
 
 [[package]]
 name = "opentelemetry-semantic-conventions"
-version = "0.66b1"
+version = "0.62b0"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "opentelemetry-api" },
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/46/e4/dbbfb2a010c4db2224a5114638acede6fe563d33cc20fb1752cebcbe6298/opentelemetry_semantic_conventions-0.66b1.tar.gz", hash = "sha256:497ca63bf383723411e8eaf60c8779e9877633c936bb641080adab59d0eb6ec8", size = 150250, upload-time = "2026-10-06T17:33:14.073Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/a3/b0/c14f723e86c049b7bf8ff431160d982519b97a7be2857ed2247377397a24/opentelemetry_semantic_conventions-0.62b0.tar.gz", hash = "sha256:cbfb3c8fc259575cf68a6e1b94083cc35adc4a6b06e8cf431efa0d62606c0097", size = 145753, upload-time = "2026-04-09T14:38:48.274Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/bc/14/67f8aa798857f8cf686f515bf93d9bb877ce952ddc8efae0fa25b45ce0d6/opentelemetry_semantic_conventions-0.66b1-py3-none-any.whl", hash = "sha256:d4cddeb4315490b35213f55e2bdc9ac54bb1e4d318927475bed62b35545e581b", size = 206279, upload-time = "2026-10-06T17:32:56.103Z" },
+    { url = "https://files.pythonhosted.org/packages/58/6c/5e86fa1759a525ef91c2d8b79d668574760ff3f900d114297765eb8786cb/opentelemetry_semantic_conventions-0.62b0-py3-none-any.whl", hash = "sha256:0ddac1ce59eaf1a827d9987ab60d9315fb27aea23304144242d1fcad9e16b489", size = 231619, upload-time = "2026-04-09T14:38:32.394Z" },
 ]
 
 [[package]]
@@ -1588,11 +1556,11 @@ wheels = [
 
 [[package]]
 name = "packaging"
-version = "26.3"
+version = "26.1"
 source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/7d/fa/3944b40b07da9ce895c0e6303a5ab7d53da063554f534556b134a54d6093/packaging-26.3.tar.gz", hash = "sha256:94edc256424af38762eb31306eed28beb9f0efc50a8837492c9d6fd6004aed79", size = 313412, upload-time = "2026-08-04T18:15:28.737Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/df/de/0d2b39fb4af88a0258f3bac87dfcbb48e73fbdea4a2ed0e2213f9a4c2f9a/packaging-26.1.tar.gz", hash = "sha256:f042152b681c4bfac5cae2742a55e103d27ab2ec0f3d88037136b6bfe7c9c5de", size = 215519, upload-time = "2026-04-14T21:12:49.362Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/63/34/ba1c580383c9eada3711951fef0795c80b829a078d72188184bcab9dd527/packaging-26.3-py3-none-any.whl", hash = "sha256:d7193f7c8e4e93f444fde0262bf90af30e16fa0ad0ad44cb553c87339b23cd1c", size = 129956, upload-time = "2026-08-04T18:15:27.159Z" },
+    { url = "https://files.pythonhosted.org/packages/7a/c2/920ef838e2f0028c8262f16101ec09ebd5969864e5a64c4c05fad0617c56/packaging-26.1-py3-none-any.whl", hash = "sha256:5d9c0669c6285e491e0ced2eee587eaf67b670d94a19e94e3984a481aba6802f", size = 95831, upload-time = "2026-04-14T21:12:47.56Z" },
 ]
 
 [[package]]
@@ -1674,7 +1642,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" } },
+    { name = "typing-extensions" },
     { name = "typing-inspection" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/09/e5/06d23afac9973109d1e3c8ad38e1547a12e860610e327c05ee686827dc37/pydantic-2.13.2.tar.gz", hash = "sha256:b418196607e61081c3226dcd4f0672f2a194828abb9109e9cfb84026564df2d1", size = 843836, upload-time = "2026-04-17T09:31:59.636Z" }
@@ -1687,7 +1655,7 @@ name = "pydantic-core"
 version = "2.46.2"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
-    { name = "typing-extensions", version = "4.15.0", source = { registry = "https://pypi.org/simple" } },
+    { name = "typing-extensions" },
 ]
 sdist = { url = "https://files.pythonhosted.org/packages/43/bb/4742f05b739b2478459bb16fa8470549518c802e06ddcf3f106c5081315e/pydantic_core-2.46.2.tar.gz", hash = "sha256:37bb079f9ee3f1a519392b73fda2a96379b31f2013c6b467fe693e7f2987f596", size = 471269, upload-time = "2026-04-17T09:10:07.017Z" }
 wheels = [
@@ -1850,8 +1818,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.15.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version >= '3.11' and python_full_version < '3.13'" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.11'" },
+    { 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 = [
@@ -2068,11 +2035,11 @@ wheels = [
 
 [[package]]
 name = "setuptools"
-version = "84.1.0"
+version = "83.0.0"
 source = { registry = "https://pypi.org/simple" }
-sdist = { url = "https://files.pythonhosted.org/packages/73/eb/7e5f628ee2eb168fecbf8026de7856b2543d6d609cc85f086b9a91ac93d6/setuptools-84.1.0.tar.gz", hash = "sha256:23657205b63d4d31395ab917815247f694aafad28cd21316bf5fd45a51048ea0", size = 1171783, upload-time = "2026-10-19T20:11:43.489Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/34/26/f5d29e25ffdb535afef2d35cdb55b325298f96debd670da4c325e08d70f4/setuptools-83.0.0.tar.gz", hash = "sha256:025bccbbf0fa05b6192bc64ae1e7b16e001fd6d6d4d5de03c97b1c1ade523bef", size = 1154254, upload-time = "2026-07-04T15:31:22.699Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/18/02/b4bbb90f8f29e334898ff45c6d9b1fffaa6f378017052b3023a06262b5f7/setuptools-84.1.0-py3-none-any.whl", hash = "sha256:5231689c6ac8156cd155cfb98c3fd6fb252c3e7e9bd3d78b64d3c55f132624c9", size = 819380, upload-time = "2026-10-19T20:11:41.684Z" },
+    { url = "https://files.pythonhosted.org/packages/5d/40/e1e72872c6354b306daef1703549e8e83b4d43cfea356311bf722a043752/setuptools-83.0.0-py3-none-any.whl", hash = "sha256:29b23c360f22f414dc7336bb39178cc7bcbf6021ed2733cde173f09dba19abb3", size = 1008090, upload-time = "2026-07-04T15:31:20.885Z" },
 ]
 
 [[package]]
@@ -2112,7 +2079,7 @@ version = "1.3.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "anyio" },
-    { name = "typing-extensions", version = "4.15.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/eb/e3/7c1dc7381d9f8ab7d854328ebfa884e62cb3f3d8549ddfd37c7814f42afa/starlette-1.3.1.tar.gz", hash = "sha256:05d0213193f2fbaae60e2ecb593b4add4262ad4e46536b54abe36f11a71724e0", size = 2703240, upload-time = "2026-06-12T09:23:11.602Z" }
 wheels = [
@@ -2256,34 +2223,17 @@ wheels = [
 name = "typing-extensions"
 version = "4.15.0"
 source = { registry = "https://pypi.org/simple" }
-resolution-markers = [
-    "python_full_version >= '3.15'",
-    "python_full_version >= '3.12' and python_full_version < '3.15' and sys_platform == 'emscripten'",
-    "python_full_version == '3.11.*' or (python_full_version >= '3.12' and python_full_version < '3.15' and sys_platform != 'emscripten')",
-]
 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.11'",
-]
-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" } },
+    { name = "typing-extensions" },
 ]
 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 = [
@@ -2425,19 +2375,18 @@ wheels = [
 
 [[package]]
 name = "virtualenv"
-version = "21.14.13"
+version = "21.7.13"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "distlib" },
     { name = "filelock" },
-    { name = "packaging" },
     { name = "platformdirs" },
     { name = "python-discovery" },
-    { name = "typing-extensions", version = "4.16.0", source = { registry = "https://pypi.org/simple" }, marker = "python_full_version < '3.11'" },
+    { name = "typing-extensions", marker = "python_full_version < '3.11'" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/70/aa/bff50daee0488e16d611258a9b6c5a1d0c9e128f8ca424e9f4e1c0444ef2/virtualenv-21.14.13.tar.gz", hash = "sha256:de5307ba4b9a0001d9c8ea02832d38f63ca432880f416c1bface61c4323fd905", size = 5570301, upload-time = "2026-10-22T20:10:16.952Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/13/50/c9b84eb106d0db420b9878dac0a386c5791726f127ce20b06897f6e3a1e9/virtualenv-21.7.13.tar.gz", hash = "sha256:0355558b6f33619aab31347e43643b0ebc97f61ea3acf617b2b69e1f8a843d11", size = 5360306, upload-time = "2026-09-18T04:35:49.354Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/bb/a9/c10d8a44a29fb94a18b43fdf11f38caca53ae7c9406f11a72b1cb8f624f1/virtualenv-21.14.13-py3-none-any.whl", hash = "sha256:5fbb04138a4861580b78ba9110d529a26bc48fcc93c8ec36bc0202eeed96a788", size = 5557094, upload-time = "2026-10-22T20:10:15.096Z" },
+    { url = "https://files.pythonhosted.org/packages/9a/ce/e74453531b0c49a58d0e8a4f9bab4495705859fee4a4f7de27d58f4a791a/virtualenv-21.7.13-py3-none-any.whl", hash = "sha256:1bea5af7463f59c4719db48fe739579a2a4f569c96f26c086edda85c96da9f59", size = 5328680, upload-time = "2026-09-18T04:35:47.194Z" },
 ]
 
 [[package]]

libs/langgraph/langgraph/_internal/_config.py

@@ -29,19 +29,7 @@ from langgraph._internal._constants import (
     NS_SEP,
 )
 
-
-class _DefaultRecursionLimit(int):
-    """The limit `ensure_config` fills in when none is given.
-
-    `merge_configs` skips values of this type rather than any equal value, so an
-    explicit limit that happens to equal the default still applies. It checks the
-    type, not identity, because copying or pickling a config rebuilds the value.
-    """
-
-
-DEFAULT_RECURSION_LIMIT = _DefaultRecursionLimit(
-    getenv("LANGGRAPH_DEFAULT_RECURSION_LIMIT", "10007")
-)
+DEFAULT_RECURSION_LIMIT = int(getenv("LANGGRAPH_DEFAULT_RECURSION_LIMIT", "10007"))
 DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOT = int(
     getenv("LANGGRAPH_DELTA_MAX_SUPERSTEPS_SINCE_SNAPSHOT", "5000")
 )
@@ -194,7 +182,7 @@ def merge_configs(*configs: RunnableConfig | None) -> RunnableConfig:
                     base.get("callbacks"), cast(Callbacks, value)
                 )
             elif key == "recursion_limit":
-                if not isinstance(config["recursion_limit"], _DefaultRecursionLimit):
+                if config["recursion_limit"] != DEFAULT_RECURSION_LIMIT:
                     base["recursion_limit"] = config["recursion_limit"]
             else:
                 base[key] = config[key]  # type: ignore[literal-required]

libs/langgraph/langgraph/pregel/remote.py

@@ -861,6 +861,11 @@ class RemoteGraph(PregelProtocol):
                     )
                 yield {"type": mode, "ns": ns, "data": chunk.data, "interrupts": ints}
             elif subgraphs:
+                if NS_SEP in chunk.event:
+                    mode, ns_ = chunk.event.split(NS_SEP, 1)
+                    ns = tuple(ns_.split(NS_SEP))
+                else:
+                    mode, ns = chunk.event, ()
                 if req_single:
                     yield ns, chunk.data
                 else:
@@ -1011,6 +1016,11 @@ class RemoteGraph(PregelProtocol):
                     )
                 yield {"type": mode, "ns": ns, "data": chunk.data, "interrupts": ints}
             elif subgraphs:
+                if NS_SEP in chunk.event:
+                    mode, ns_ = chunk.event.split(NS_SEP, 1)
+                    ns = tuple(ns_.split(NS_SEP))
+                else:
+                    mode, ns = chunk.event, ()
                 if req_single:
                     yield ns, chunk.data
                 else:

libs/langgraph/pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "langgraph"
-version = "1.2.17"
+version = "1.2.16"
 description = "Building stateful, multi-actor applications with LLMs"
 authors = []
 requires-python = ">=3.10"

libs/langgraph/tests/test_config_async.py

@@ -1,19 +1,11 @@
-from collections.abc import Callable
-
 import pytest
 from langchain_core.callbacks import AsyncCallbackManager, BaseCallbackHandler
 
-from langgraph._internal._config import (
-    DEFAULT_RECURSION_LIMIT,
-    get_async_callback_manager_for_config,
-)
+from langgraph._internal._config import get_async_callback_manager_for_config
 from langgraph.graph import StateGraph
-from langgraph.pregel import Pregel
 
 pytestmark = pytest.mark.anyio
 
-EXPLICIT_DEFAULT_LIMIT = int(DEFAULT_RECURSION_LIMIT)
-
 
 def test_new_async_manager_includes_tags() -> None:
     config = {"callbacks": None}
@@ -122,27 +114,3 @@ async def test_with_config_tags_preserved_on_invoke() -> None:
     await graph.ainvoke({}, {"tags": ["invoke"]})
     assert "bound" in captured, "bound tag was dropped by ensure_config overwrite"
     assert "invoke" in captured, "invoke-time tag not present"
-
-
-@pytest.mark.parametrize(
-    "rebind",
-    [
-        lambda g: g.with_config(recursion_limit=EXPLICIT_DEFAULT_LIMIT),
-        lambda g: g.with_config({"recursion_limit": EXPLICIT_DEFAULT_LIMIT}),
-        lambda g: g.with_config(
-            {"recursion_limit": 1}, recursion_limit=EXPLICIT_DEFAULT_LIMIT
-        ),
-        lambda g: g.with_config(recursion_limit=EXPLICIT_DEFAULT_LIMIT).with_config(
-            tags=["t"]
-        ),
-    ],
-    ids=["kwarg", "config", "kwarg_over_config", "kept_by_later_with_config"],
-)
-def test_with_config_applies_recursion_limit_equal_to_default(
-    rebind: Callable[[Pregel], Pregel],
-) -> None:
-    builder = StateGraph(dict)
-    builder.add_node("node", lambda state: state)
-    builder.add_edge("__start__", "node")
-    graph = builder.compile().with_config(recursion_limit=EXPLICIT_DEFAULT_LIMIT + 1)
-    assert rebind(graph).config["recursion_limit"] == EXPLICIT_DEFAULT_LIMIT

libs/langgraph/tests/test_remote_graph.py

@@ -819,50 +819,6 @@ async def test_astream():
     ]
 
 
-_CALLER_CONFIG: RunnableConfig = {
-    "configurable": {"thread_id": "thread_1", "checkpoint_ns": "outer:123"}
-}
-_SUBGRAPH_PARTS = [
-    StreamPart(event="values|sub:abc", data={"chunk": "inner"}),
-    StreamPart(event="values", data={"chunk": "root"}),
-]
-_CALLER_PREFIXED = [
-    (("outer:123", "sub:abc"), {"chunk": "inner"}),
-    (("outer:123",), {"chunk": "root"}),
-]
-
-
-def test_stream_subgraphs_keeps_caller_namespace():
-    mock_sync_client = MagicMock()
-    mock_sync_client.runs.stream.return_value = _SUBGRAPH_PARTS
-    remote_pregel = RemoteGraph("test_graph_id", sync_client=mock_sync_client)
-
-    stream_parts = list(
-        remote_pregel.stream(
-            {"input": "data"}, _CALLER_CONFIG, stream_mode="values", subgraphs=True
-        )
-    )
-
-    assert stream_parts == _CALLER_PREFIXED
-
-
-async def test_astream_subgraphs_keeps_caller_namespace():
-    mock_async_client = MagicMock()
-    async_iter = MagicMock()
-    async_iter.__aiter__.return_value = _SUBGRAPH_PARTS
-    mock_async_client.runs.stream.return_value = async_iter
-    remote_pregel = RemoteGraph("test_graph_id", client=mock_async_client)
-
-    stream_parts = [
-        part
-        async for part in remote_pregel.astream(
-            {"input": "data"}, _CALLER_CONFIG, stream_mode="values", subgraphs=True
-        )
-    ]
-
-    assert stream_parts == _CALLER_PREFIXED
-
-
 def test_invoke():
     # set up test
     mock_sync_client = MagicMock()

libs/langgraph/tests/test_utils.py

@@ -1,6 +1,4 @@
-import copy
 import functools
-import pickle
 import sys
 import uuid
 from collections.abc import Callable
@@ -27,7 +25,6 @@ from pydantic import BaseModel, Field
 from typing_extensions import NotRequired, Required, TypedDict
 
 from langgraph._internal._config import (
-    DEFAULT_RECURSION_LIMIT,
     _is_not_empty,
     _merge_callbacks,
     ensure_config,
@@ -623,30 +620,6 @@ def test_merge_configs_merges_metadata_lc_versions() -> None:
     assert merged["metadata"]["lc_agent_name"] == "agent"
 
 
-@pytest.mark.parametrize(
-    "rebuild",
-    [
-        lambda config: config,
-        copy.deepcopy,
-        lambda config: pickle.loads(pickle.dumps(config)),
-    ],
-    ids=["as_is", "deepcopy", "pickle"],
-)
-def test_merge_configs_skips_the_injected_default_recursion_limit(
-    rebuild: Callable[[RunnableConfig], RunnableConfig],
-) -> None:
-    merged = merge_configs({"recursion_limit": 50}, rebuild(ensure_config()))
-    assert merged["recursion_limit"] == 50
-
-
-def test_merge_configs_applies_an_explicit_recursion_limit_equal_to_default() -> None:
-    explicit_default = int(DEFAULT_RECURSION_LIMIT)
-    merged = merge_configs(
-        {"recursion_limit": 50}, {"recursion_limit": explicit_default}
-    )
-    assert merged["recursion_limit"] == explicit_default
-
-
 def test_ensure_config_merges_metadata_lc_versions() -> None:
     a = {
         "metadata": {

libs/langgraph/uv.lock

@@ -1,5 +1,5 @@
 version = 1
-revision = 5
+revision = 3
 requires-python = ">=3.10"
 resolution-markers = [
     "python_full_version >= '3.15'",
@@ -931,6 +931,18 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/d2/23/408243171aa9aaba178d3e2559159c24c1171a641aa83b67bdd3394ead8e/idna-3.15-py3-none-any.whl", hash = "sha256:048adeaf8c2d788c40fee287673ccaa74c24ffd8dcf09ffa555a2fbb59f10ac8", size = 72340, upload-time = "2026-05-12T22:45:55.733Z" },
 ]
 
+[[package]]
+name = "importlib-metadata"
+version = "8.7.1"
+source = { registry = "https://pypi.org/simple" }
+dependencies = [
+    { name = "zipp" },
+]
+sdist = { url = "https://files.pythonhosted.org/packages/f3/49/3b30cad09e7771a4982d9975a8cbf64f00d4a1ececb53297f1d9a7be1b10/importlib_metadata-8.7.1.tar.gz", hash = "sha256:49fef1ae6440c182052f407c8d34a68f72efc36db9ca90dc0113398f2fdde8bb", size = 57107, upload-time = "2025-12-21T10:00:19.278Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/fa/5e/f8e9a1d23b9c20a551a8a02ea3637b4642e22c2626e3a13a9a29cdea99eb/importlib_metadata-8.7.1-py3-none-any.whl", hash = "sha256:5a1f80bf1daa489495071efbb095d75a634cf28a8bc299581244063b53176151", size = 27865, upload-time = "2025-12-21T10:00:18.329Z" },
+]
+
 [[package]]
 name = "iniconfig"
 version = "2.3.0"
@@ -1439,7 +1451,7 @@ wheels = [
 
 [[package]]
 name = "langgraph"
-version = "1.2.17"
+version = "1.2.16"
 source = { editable = "." }
 dependencies = [
     { name = "langchain-core" },
@@ -1907,7 +1919,7 @@ requires-dist = [
     { name = "langchain-core", specifier = ">=1.4.0,<2" },
     { name = "langchain-protocol", specifier = ">=0.0.15" },
     { name = "orjson", specifier = ">=3.11.5" },
-    { name = "websockets", specifier = ">=14" },
+    { name = "websockets", specifier = ">=14,<17" },
 ]
 
 [package.metadata.requires-dev]
@@ -2099,7 +2111,7 @@ wheels = [
 
 [[package]]
 name = "nbconvert"
-version = "7.17.2"
+version = "7.17.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "beautifulsoup4" },
@@ -2117,9 +2129,9 @@ dependencies = [
     { name = "pygments" },
     { name = "traitlets" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/53/6a/252c7620305a9661205aed7a2a4b3592f5207bfca56ad11b7dea2c5ec2f6/nbconvert-7.17.2.tar.gz", hash = "sha256:344a218e8595117ce37396ed025d994f146d076226ebac59255a2fa085ab24d8", size = 865989, upload-time = "2026-10-12T09:11:19.583Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/01/b1/708e53fe2e429c103c6e6e159106bcf0357ac41aa4c28772bd8402339051/nbconvert-7.17.1.tar.gz", hash = "sha256:34d0d0a7e73ce3cbab6c5aae8f4f468797280b01fd8bd2ca746da8569eddd7d2", size = 865311, upload-time = "2026-04-08T00:44:14.914Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/81/fd/a8d457af68848a8e5c12dd1d84ff35c415db471af78280e0703db4efbb12/nbconvert-7.17.2-py3-none-any.whl", hash = "sha256:6a143c11c00bf831604da4b1be4347d36ea52367057eb920135d69bc2862fed2", size = 262094, upload-time = "2026-10-12T09:11:17.215Z" },
+    { url = "https://files.pythonhosted.org/packages/67/f8/bb0a9d5f46819c821dc1f004aa2cc29b1d91453297dbf5ff20470f00f193/nbconvert-7.17.1-py3-none-any.whl", hash = "sha256:aa85c087b435e7bf1ffd03319f658e285f2b89eccab33bc1ba7025495ab3e7c8", size = 261927, upload-time = "2026-04-08T00:44:12.845Z" },
 ]
 
 [[package]]
@@ -2177,114 +2189,84 @@ wheels = [
 
 [[package]]
 name = "opentelemetry-api"
-version = "1.45.1"
+version = "1.39.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
+    { name = "importlib-metadata" },
     { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/2e/02/6e0ae9cc61bd3169d401077b507b3ebc344745171e1051ab430be012dcd9/opentelemetry_api-1.45.1.tar.gz", hash = "sha256:aa38ed19bcc084ba42782a73255b3582283eced7ad6dddbd6695189e69adfb75", size = 72804, upload-time = "2026-10-06T17:32:58.133Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/97/b9/3161be15bb8e3ad01be8be5a968a9237c3027c5be504362ff800fca3e442/opentelemetry_api-1.39.1.tar.gz", hash = "sha256:fbde8c80e1b937a2c61f20347e91c0c18a1940cecf012d62e65a7caf08967c9c", size = 65767, upload-time = "2025-12-11T13:32:39.182Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/1e/41/f7dcf80b81ee8e71c1a2b59f14208bc723edbd89ed027a73b175abf6348e/opentelemetry_api-1.45.1-py3-none-any.whl", hash = "sha256:b31553efa588ae44bc306f863c785c5333a9ecc091248c6ee68b4b6c87fdedfb", size = 60256, upload-time = "2026-10-06T17:32:33.506Z" },
-]
-
-[[package]]
-name = "opentelemetry-exporter-http-transport"
-version = "0.66b1"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "opentelemetry-api" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/62/0c/e3ebdb4b507f66afcc905e6885a4946969bd75b45988492643356fbbdc63/opentelemetry_exporter_http_transport-0.66b1.tar.gz", hash = "sha256:443080203bf52586ce0b2ad901e8951c61833eab1aa539ae6f1f16fe9e8e7952", size = 11693, upload-time = "2026-10-06T17:32:59.65Z" }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/04/69/6af86ff66492b481c6a4c05dcfd68beb47ed8ba046440a26a2aac76b95c7/opentelemetry_exporter_http_transport-0.66b1-py3-none-any.whl", hash = "sha256:2f95404bdee7f9d2d529c7de56c7bd86d014d774d8fbf137810e0167f8a492bf", size = 12155, upload-time = "2026-10-06T17:32:35.454Z" },
-]
-
-[package.optional-dependencies]
-requests = [
-    { name = "requests" },
-]
-
-[[package]]
-name = "opentelemetry-exporter-otlp-common"
-version = "0.66b1"
-source = { registry = "https://pypi.org/simple" }
-dependencies = [
-    { name = "opentelemetry-sdk" },
-]
-sdist = { url = "https://files.pythonhosted.org/packages/cb/19/41de712173f43057e4532d42ece7d0c6d4210d353e5752433cb14987643f/opentelemetry_exporter_otlp_common-0.66b1.tar.gz", hash = "sha256:6b1403487a2185ac1feb45fd5546fdf8630ce71c36bcefaadf51e2130e9e23f9", size = 14325, upload-time = "2026-10-06T17:33:01.725Z" }
-wheels = [
-    { url = "https://files.pythonhosted.org/packages/fc/39/8c23d67665c762aa51840fa06f86e902e8f6f1693bc8d7e3d98cd6e2f753/opentelemetry_exporter_otlp_common-0.66b1-py3-none-any.whl", hash = "sha256:00ff8592c3a7cb729ff3fdc7ffa12372c243bdf2163e80c180994d0c7bd83ee9", size = 12385, upload-time = "2026-10-06T17:32:38.177Z" },
+    { url = "https://files.pythonhosted.org/packages/cf/df/d3f1ddf4bb4cb50ed9b1139cc7b1c54c34a1e7ce8fd1b9a37c0d1551a6bd/opentelemetry_api-1.39.1-py3-none-any.whl", hash = "sha256:2edd8463432a7f8443edce90972169b195e7d6a05500cd29e6d13898187c9950", size = 66356, upload-time = "2025-12-11T13:32:17.304Z" },
 ]
 
 [[package]]
 name = "opentelemetry-exporter-otlp-proto-common"
-version = "1.45.1"
+version = "1.39.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "opentelemetry-proto" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/c1/8e/65e85e5137991a3c493b11682151d198638a5bc1dd4b4c5f67e013c57d7c/opentelemetry_exporter_otlp_proto_common-1.45.1.tar.gz", hash = "sha256:2e4adcc3a67bcf57804fc49514f0ef64974ca7590aa3491da389852b4a0628f6", size = 18873, upload-time = "2026-10-06T17:33:04.471Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/e9/9d/22d241b66f7bbde88a3bfa6847a351d2c46b84de23e71222c6aae25c7050/opentelemetry_exporter_otlp_proto_common-1.39.1.tar.gz", hash = "sha256:763370d4737a59741c89a67b50f9e39271639ee4afc999dadfe768541c027464", size = 20409, upload-time = "2025-12-11T13:32:40.885Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/84/aa/92f225d353904e7f70b8b3e3c1b02db0cf56f744c2e83c581dc372e78873/opentelemetry_exporter_otlp_proto_common-1.45.1-py3-none-any.whl", hash = "sha256:2f446183ae7047b036226f1d846c41a834b0e8755ad13b51a51dd38952eb466c", size = 15393, upload-time = "2026-10-06T17:32:41.911Z" },
+    { url = "https://files.pythonhosted.org/packages/8c/02/ffc3e143d89a27ac21fd557365b98bd0653b98de8a101151d5805b5d4c33/opentelemetry_exporter_otlp_proto_common-1.39.1-py3-none-any.whl", hash = "sha256:08f8a5862d64cc3435105686d0216c1365dc5701f86844a8cd56597d0c764fde", size = 18366, upload-time = "2025-12-11T13:32:20.2Z" },
 ]
 
 [[package]]
 name = "opentelemetry-exporter-otlp-proto-http"
-version = "1.45.1"
+version = "1.39.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "googleapis-common-protos" },
     { name = "opentelemetry-api" },
-    { name = "opentelemetry-exporter-http-transport", extra = ["requests"] },
-    { name = "opentelemetry-exporter-otlp-common" },
     { name = "opentelemetry-exporter-otlp-proto-common" },
     { name = "opentelemetry-proto" },
     { name = "opentelemetry-sdk" },
     { name = "requests" },
     { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/1b/17/26487707ea4caa97b17e6e4b5fa72133a53512ffa2f5cf7a49ef284b29cb/opentelemetry_exporter_otlp_proto_http-1.45.1.tar.gz", hash = "sha256:45c218405ce3fd879596924b1874bf9a8f6880206d61065c5a912c8e5c297fb7", size = 28839, upload-time = "2026-10-06T17:33:05.713Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/80/04/2a08fa9c0214ae38880df01e8bfae12b067ec0793446578575e5080d6545/opentelemetry_exporter_otlp_proto_http-1.39.1.tar.gz", hash = "sha256:31bdab9745c709ce90a49a0624c2bd445d31a28ba34275951a6a362d16a0b9cb", size = 17288, upload-time = "2025-12-11T13:32:42.029Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/aa/1f/517eaa0187ba106a9da97160ce2add3a371812681dc440930b267f714e42/opentelemetry_exporter_otlp_proto_http-1.45.1-py3-none-any.whl", hash = "sha256:24a97cf3753c7fb52fad44a696e452ff371686339e2acf3309e2eda3d0230700", size = 22180, upload-time = "2026-10-06T17:32:43.946Z" },
+    { url = "https://files.pythonhosted.org/packages/95/f1/b27d3e2e003cd9a3592c43d099d2ed8d0a947c15281bf8463a256db0b46c/opentelemetry_exporter_otlp_proto_http-1.39.1-py3-none-any.whl", hash = "sha256:d9f5207183dd752a412c4cd564ca8875ececba13be6e9c6c370ffb752fd59985", size = 19641, upload-time = "2025-12-11T13:32:22.248Z" },
 ]
 
 [[package]]
 name = "opentelemetry-proto"
-version = "1.45.1"
+version = "1.39.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "protobuf" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/4b/7f/15f014fb195da6c2dbb6c71399b8e76824878718e94de6454038488eed28/opentelemetry_proto-1.45.1.tar.gz", hash = "sha256:79e0fb95e4616691a469439238aa9224d75779b3e108e895d1aa125ab29ca77c", size = 46488, upload-time = "2026-10-06T17:33:11.49Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/49/1d/f25d76d8260c156c40c97c9ed4511ec0f9ce353f8108ca6e7561f82a06b2/opentelemetry_proto-1.39.1.tar.gz", hash = "sha256:6c8e05144fc0d3ed4d22c2289c6b126e03bcd0e6a7da0f16cedd2e1c2772e2c8", size = 46152, upload-time = "2025-12-11T13:32:48.681Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/ab/9a/42ec8180a769516ae757e893b69736826efceac7332553915b4528a91c6d/opentelemetry_proto-1.45.1-py3-none-any.whl", hash = "sha256:f38e2a8413053c180cd3d2637fbb279673ec2f6a6e09c995aafa2f452c52b46e", size = 72488, upload-time = "2026-10-06T17:32:53.057Z" },
+    { url = "https://files.pythonhosted.org/packages/51/95/b40c96a7b5203005a0b03d8ce8cd212ff23f1793d5ba289c87a097571b18/opentelemetry_proto-1.39.1-py3-none-any.whl", hash = "sha256:22cdc78efd3b3765d09e68bfbd010d4fc254c9818afd0b6b423387d9dee46007", size = 72535, upload-time = "2025-12-11T13:32:33.866Z" },
 ]
 
 [[package]]
 name = "opentelemetry-sdk"
-version = "1.45.1"
+version = "1.39.1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "opentelemetry-api" },
     { name = "opentelemetry-semantic-conventions" },
     { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/a1/79/7392e21a1c8f0c61d90b223e31c7e48cb9d452e91a6b820ad24cca5f23c4/opentelemetry_sdk-1.45.1.tar.gz", hash = "sha256:63d24a6ca645019a631e6a51999c73e93adcac1196ca640b8ae78a7cc4762bf3", size = 218324, upload-time = "2026-10-06T17:33:13.26Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/eb/fb/c76080c9ba07e1e8235d24cdcc4d125ef7aa3edf23eb4e497c2e50889adc/opentelemetry_sdk-1.39.1.tar.gz", hash = "sha256:cf4d4563caf7bff906c9f7967e2be22d0d6b349b908be0d90fb21c8e9c995cc6", size = 171460, upload-time = "2025-12-11T13:32:49.369Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/95/3c/87c42b4bd6dd297536f04cd9383d212ac557ecd49f2cbdcd46da1c9ef5c8/opentelemetry_sdk-1.45.1-py3-none-any.whl", hash = "sha256:c604c11dc429810812348989115fa44bd558772a3d7442afc43d024f2c250ca4", size = 140063, upload-time = "2026-10-06T17:32:55.04Z" },
+    { url = "https://files.pythonhosted.org/packages/7c/98/e91cf858f203d86f4eccdf763dcf01cf03f1dae80c3750f7e635bfa206b6/opentelemetry_sdk-1.39.1-py3-none-any.whl", hash = "sha256:4d5482c478513ecb0a5d938dcc61394e647066e0cc2676bee9f3af3f3f45f01c", size = 132565, upload-time = "2025-12-11T13:32:35.069Z" },
 ]
 
 [[package]]
 name = "opentelemetry-semantic-conventions"
-version = "0.66b1"
+version = "0.60b1"
 source = { registry = "https://pypi.org/simple" }
 dependencies = [
     { name = "opentelemetry-api" },
     { name = "typing-extensions" },
 ]
-sdist = { url = "https://files.pythonhosted.org/packages/46/e4/dbbfb2a010c4db2224a5114638acede6fe563d33cc20fb1752cebcbe6298/opentelemetry_semantic_conventions-0.66b1.tar.gz", hash = "sha256:497ca63bf383723411e8eaf60c8779e9877633c936bb641080adab59d0eb6ec8", size = 150250, upload-time = "2026-10-06T17:33:14.073Z" }
+sdist = { url = "https://files.pythonhosted.org/packages/91/df/553f93ed38bf22f4b999d9be9c185adb558982214f33eae539d3b5cd0858/opentelemetry_semantic_conventions-0.60b1.tar.gz", hash = "sha256:87c228b5a0669b748c76d76df6c364c369c28f1c465e50f661e39737e84bc953", size = 137935, upload-time = "2025-12-11T13:32:50.487Z" }
 wheels = [
-    { url = "https://files.pythonhosted.org/packages/bc/14/67f8aa798857f8cf686f515bf93d9bb877ce952ddc8efae0fa25b45ce0d6/opentelemetry_semantic_conventions-0.66b1-py3-none-any.whl", hash = "sha256:d4cddeb4315490b35213f55e2bdc9ac54bb1e4d318927475bed62b35545e581b", size = 206279, upload-time = "2026-10-06T17:32:56.103Z" },
+    { url = "https://files.pythonhosted.org/packages/7a/5e/5958555e09635d09b75de3c4f8b9cae7335ca545d77392ffe7331534c402/opentelemetry_semantic_conventions-0.60b1-py3-none-any.whl", hash = "sha256:9fa8c8b0c110da289809292b0591220d3a7b53c1526a23021e977d68597893fb", size = 219982, upload-time = "2025-12-11T13:32:36.955Z" },
 ]
 
 [[package]]
@@ -4257,6 +4239,15 @@ wheels = [
     { url = "https://files.pythonhosted.org/packages/7d/f3/1ac078fc8fceadcf066469acecacb35d2821cbfaf7d6fc5ac2107c7a314d/xxhash-4.0.1-pp311-pypy311_pp73-win_amd64.whl", hash = "sha256:fac4832b638000106207bc44e44b9616a6a416aaee56c62b01d61f3705e49f58", size = 37252, upload-time = "2026-08-17T08:24:06.652Z" },
 ]
 
+[[package]]
+name = "zipp"
+version = "3.23.0"
+source = { registry = "https://pypi.org/simple" }
+sdist = { url = "https://files.pythonhosted.org/packages/e3/02/0f2892c661036d50ede074e376733dca2ae7c6eb617489437771209d4180/zipp-3.23.0.tar.gz", hash = "sha256:a07157588a12518c9d4034df3fbbee09c814741a33ff63c05fa29d26a2404166", size = 25547, upload-time = "2025-06-08T17:06:39.4Z" }
+wheels = [
+    { url = "https://files.pythonhosted.org/packages/2e/54/647ade08bf0db230bfea292f893923872fd20be6ac6f53b2b936ba839d75/zipp-3.23.0-py3-none-any.whl", hash = "sha256:071652d6115ed432f5ce1d34c336c0adfd6a884660d1e9712a256d3d3bd4b14e", size = 10276, upload-time = "2025-06-08T17:06:38.034Z" },
+]
+
 [[package]]
 name = "zstandard"
 version = "0.25.0"

libs/prebuilt/uv.lock

@@ -286,7 +286,7 @@ wheels = [
 
 [[package]]
 name = "langgraph"
-version = "1.2.17"
+version = "1.2.16"
 source = { editable = "../langgraph" }
 dependencies = [
     { name = "langchain-core" },
@@ -614,7 +614,7 @@ requires-dist = [
     { name = "langchain-core", specifier = ">=1.4.0,<2" },
     { name = "langchain-protocol", specifier = ">=0.0.15" },
     { name = "orjson", specifier = ">=3.11.5" },
-    { name = "websockets", specifier = ">=14" },
+    { name = "websockets", specifier = ">=14,<17" },
 ]
 
 [package.metadata.requires-dev]

libs/sdk-py/CHANGELOG.md

@@ -34,14 +34,6 @@
 - **`thread.output`** — awaitable that resolves to the terminal thread state
   `values` dict after the run lifecycle completes.
 
-- **`Priority` (beta)** — register an async function with `@priority.assign`
-  and name the object in the `priority` section of `langgraph.json`. The
-  server calls the function with a `PriorityContext` at the first run on a
-  thread with no settings and stores the `PrioritySettings` it returns
-  (`priority`, `fairness_group`, `fairness_weight`) on the thread. Requires
-  `langgraph-api` 0.18.0 or later and a `langgraph-cli` that supports the
-  section; older versions of either ignore it.
-
 ### Changed
 
 - `client.threads.stream()` now accepts `transport="sse"` (default) or

libs/sdk-py/langgraph_sdk/__init__.py

@@ -2,19 +2,14 @@ from langgraph_sdk.auth import Auth
 from langgraph_sdk.client import get_client, get_sync_client
 from langgraph_sdk.encryption import Encryption
 from langgraph_sdk.encryption.types import DecryptResult, EncryptionContext
-from langgraph_sdk.priority import Priority
-from langgraph_sdk.priority.types import PriorityContext, PrioritySettings
 
-__version__ = "0.4.9"
+__version__ = "0.4.8"
 
 __all__ = [
     "Auth",
     "DecryptResult",
     "Encryption",
     "EncryptionContext",
-    "Priority",
-    "PriorityContext",
-    "PrioritySettings",
     "get_client",
     "get_sync_client",
 ]

libs/sdk-py/langgraph_sdk/priority/__init__.py

@@ -1,155 +0,0 @@
-"""Custom run priority for LangGraph.
-
-.. warning::
-    This API is in beta and may change in future versions.
-
-This module lets developers decide the priority settings of each thread with
-an async function that the server calls at the first run on a thread with no
-settings. The function is registered on an object that `langgraph.json` names,
-and runs server-side.
-"""
-
-from __future__ import annotations
-
-import functools
-import inspect
-import typing
-import warnings
-from collections.abc import Awaitable, Callable
-
-from langgraph_sdk.encryption import DuplicateHandlerError, LangGraphBetaWarning
-from langgraph_sdk.priority import types
-
-_AssignHandler = Callable[
-    [types.PriorityContext], Awaitable[types.PrioritySettings | None]
-]
-_AssignHandlerT = typing.TypeVar("_AssignHandlerT", bound=_AssignHandler)
-
-
-@functools.lru_cache(maxsize=1)
-def _warn_priority_beta() -> None:
-    warnings.warn(
-        "The Priority API is in beta and may change in future versions.",
-        LangGraphBetaWarning,
-        stacklevel=4,
-    )
-
-
-def _validate_handler(fn: typing.Callable) -> None:
-    """Validate that the assign handler is async and takes one parameter.
-
-    Raises:
-        TypeError: If the handler is not an async function or has wrong parameter count
-    """
-    if not inspect.iscoroutinefunction(fn):
-        raise TypeError(
-            f"Priority assign handler must be an async function, got {type(fn)}"
-        )
-
-    sig = inspect.signature(fn)
-    params = [
-        p
-        for p in sig.parameters.values()
-        if p.kind in (p.POSITIONAL_ONLY, p.POSITIONAL_OR_KEYWORD)
-    ]
-    if len(params) != 1:
-        raise TypeError(
-            "Priority assign handler must accept exactly 1 parameter (ctx), "
-            f"got {len(params)}"
-        )
-
-
-class Priority:
-    """Decide the priority settings of your LangGraph application's threads.
-
-    .. warning::
-        This API is in beta and may change in future versions.
-
-    To use, create a separate Python file and add the path to the file to your
-    LangGraph API configuration file (`langgraph.json`). Within that file, create
-    an instance of the Priority class and register an assign function with
-    `@priority.assign`.
-
-    Example `langgraph.json` file:
-
-    ```json
-    {
-      "dependencies": ["."],
-      "graphs": {
-        "agent": "./my_agent/agent.py:graph"
-      },
-      "env": ".env",
-      "priority": {
-        "path": "./priority.py:priority"
-      }
-    }
-    ```
-
-    The server calls the assign function at the first run on a thread with no
-    settings, which can come long after the thread was created, and stores the
-    settings it returns on the thread. Later runs on the thread use the stored
-    settings. The function can be called more than once for one thread, for
-    example after it raises, and only one result is stored, so keep it free of
-    side effects.
-
-    ???+ example "Basic Usage"
-
-        ```python
-        from langgraph_sdk import Priority, PriorityContext, PrioritySettings
-
-        priority = Priority()
-
-        @priority.assign
-        async def assign(ctx: PriorityContext) -> PrioritySettings | None:
-            return {
-                "priority": 3 if "premium" in ctx.permissions else 0,
-                # Stored unencrypted, so an opaque ID rather than personal data.
-                "fairness_group": ctx.user["org_id"],
-            }
-        ```
-    """
-
-    __slots__ = ("_assign_handler",)
-
-    types = types
-    """Reference to priority type definitions.
-
-    Provides access to the type definitions used by the priority system:
-    PriorityContext and PrioritySettings.
-    """
-
-    def __init__(self) -> None:
-        """Initialize the Priority instance."""
-        _warn_priority_beta()
-        self._assign_handler: _AssignHandler | None = None
-
-    def assign(self, fn: _AssignHandlerT) -> _AssignHandlerT:
-        """Register the function that assigns a thread's priority settings.
-
-        The function receives a `PriorityContext` and returns `PrioritySettings`,
-        or `None` for the defaults.
-
-        Example:
-            ```python
-            @priority.assign
-            async def assign(ctx: PriorityContext) -> PrioritySettings | None:
-                if ctx.cron_id is not None:
-                    return {"priority": -2}
-                return None
-            ```
-
-        Args:
-            fn: The assign handler function
-
-        Returns:
-            The registered handler function
-
-        Raises:
-            DuplicateHandlerError: If an assign handler is already registered
-            TypeError: If the handler has an invalid signature
-        """
-        if self._assign_handler is not None:
-            raise DuplicateHandlerError("Priority assign handler already registered")
-        _validate_handler(fn)
-        self._assign_handler = fn
-        return fn

libs/sdk-py/langgraph_sdk/priority/types.py

@@ -1,67 +0,0 @@
-"""Priority types for LangGraph.
-
-This module defines the context the server passes to the function registered
-with `@priority.assign`, and the settings that function returns.
-"""
-
-from __future__ import annotations
-
-import typing
-from collections.abc import Sequence
-from dataclasses import dataclass
-
-from langgraph_sdk.auth.types import BaseUser
-
-
-@dataclass(frozen=True, slots=True)
-class PriorityContext:
-    """Context passed to the `@priority.assign` function at the first run on a thread with no settings."""
-
-    user: BaseUser
-    """The user from the deployment's auth, custom auth or LangSmith auth. Without auth, `user.identity` is empty."""
-
-    permissions: Sequence[str]
-    """The user's permissions from the same auth. Without auth, it's empty."""
-
-    thread_id: str | None
-    """The thread's ID, or `None` when the run creates its thread without being given an ID."""
-
-    thread_metadata: dict[str, typing.Any]
-    """The thread's metadata."""
-
-    assistant_id: str
-    """The ID of the assistant the run uses."""
-
-    graph_id: str
-    """The ID of the graph the assistant runs."""
-
-    assistant_metadata: dict[str, typing.Any]
-    """The assistant's metadata."""
-
-    run_metadata: dict[str, typing.Any]
-    """The run's metadata."""
-
-    cron_id: str | None
-    """The ID of the cron that started the run, or `None` when no cron started it."""
-
-
-class PrioritySettings(typing.TypedDict, total=False):
-    """Priority settings returned by the `@priority.assign` function.
-
-    Every key is optional: a missing key or a key set to `None` takes its
-    default, and returning `None` instead of a dict gives every key its default.
-    A value outside its range, or an empty `fairness_group`, is an error.
-    """
-
-    priority: int | None
-    """An integer from -5 to 5, where 5 runs first and -5 runs last. Defaults to 0."""
-
-    fairness_group: str | None
-    """The thread's fairness group, a non-empty string. Defaults to `"default"`.
-
-    The server stores it unencrypted, even when the deployment uses custom
-    encryption, so use an opaque ID rather than personal data.
-    """
-
-    fairness_weight: int | None
-    """The weight of the thread's fairness group, an integer from 1 to 100. Defaults to 1."""

libs/sdk-py/pyproject.toml

@@ -16,7 +16,7 @@ dependencies = [
     "orjson>=3.11.5",
     "langchain-protocol>=0.0.15",
     "langchain-core>=1.4.0,<2",
-    "websockets>=14",
+    "websockets>=14,<17",
 ]
 
 [tool.hatch.version]

libs/sdk-py/tests/test_priority.py

@@ -1,128 +0,0 @@
-import dataclasses
-
-import pytest
-
-import langgraph_sdk
-from langgraph_sdk import Priority, PriorityContext, PrioritySettings
-from langgraph_sdk.encryption import DuplicateHandlerError, LangGraphBetaWarning
-from langgraph_sdk.priority import _warn_priority_beta
-
-
-class _User:
-    is_authenticated = True
-    display_name = "user-1"
-    identity = "user-1"
-    permissions: tuple[str, ...] = ()
-
-    def __getitem__(self, key):
-        return getattr(self, key)
-
-    def __contains__(self, key):
-        return hasattr(self, key)
-
-    def __iter__(self):
-        return iter(("identity", "display_name", "is_authenticated", "permissions"))
-
-
-def _context(thread_id: str | None) -> PriorityContext:
-    return PriorityContext(
-        user=_User(),
-        permissions=[],
-        thread_id=thread_id,
-        thread_metadata={},
-        assistant_id="assistant-1",
-        graph_id="agent",
-        assistant_metadata={"tier": "gold"},
-        run_metadata={},
-        cron_id=None,
-    )
-
-
-async def _no_params() -> PrioritySettings | None:
-    return None
-
-
-async def _two_params(_ctx: PriorityContext, _extra: object) -> PrioritySettings | None:
-    return None
-
-
-def test_priority_and_its_types_are_exported():
-    assert {"Priority", "PriorityContext", "PrioritySettings"} <= set(
-        langgraph_sdk.__all__
-    )
-    assert Priority.types.PriorityContext is PriorityContext
-    assert Priority.types.PrioritySettings is PrioritySettings
-
-
-def test_construction_warns_that_priority_is_beta():
-    # The warning fires once per process, so an earlier test may have used it up.
-    _warn_priority_beta.cache_clear()
-    with pytest.warns(LangGraphBetaWarning, match="Priority API is in beta"):
-        Priority()
-
-
-def test_assign_registers_and_returns_the_function():
-    priority = Priority()
-
-    async def assign(_ctx: PriorityContext) -> PrioritySettings | None:
-        return {"priority": 3, "fairness_group": "org-42"}
-
-    assert priority.assign(assign) is assign
-    assert priority._assign_handler is assign
-
-
-def test_assign_rejects_a_sync_function():
-    priority = Priority()
-
-    def assign(_ctx: PriorityContext) -> PrioritySettings | None:
-        return None
-
-    with pytest.raises(TypeError, match="must be an async function"):
-        priority.assign(assign)  # ty: ignore[invalid-argument-type]
-    assert priority._assign_handler is None
-
-
-@pytest.mark.parametrize("fn", [_no_params, _two_params])
-def test_assign_rejects_the_wrong_number_of_parameters(fn):
-    priority = Priority()
-
-    with pytest.raises(TypeError, match="must accept exactly 1 parameter"):
-        priority.assign(fn)
-    assert priority._assign_handler is None
-
-
-def test_assign_rejects_a_second_function():
-    priority = Priority()
-
-    @priority.assign
-    async def first(_ctx: PriorityContext) -> PrioritySettings | None:
-        return None
-
-    with pytest.raises(DuplicateHandlerError):
-
-        @priority.assign
-        async def second(_ctx: PriorityContext) -> PrioritySettings | None:
-            return None
-
-    assert priority._assign_handler is first
-
-
-def test_context_accepts_no_thread_id():
-    # `make lint` type-checks this call too, so `thread_id` must accept None there.
-    assert _context(thread_id=None).thread_id is None
-
-
-def test_context_is_frozen():
-    ctx = _context(thread_id="thread-1")
-
-    with pytest.raises(dataclasses.FrozenInstanceError):
-        ctx.thread_id = "thread-2"  # ty: ignore[invalid-assignment]
-
-
-def test_every_settings_key_is_optional():
-    assert PrioritySettings.__optional_keys__ == {
-        "priority",
-        "fairness_group",
-        "fairness_weight",
-    }
-    assert PrioritySettings.__required_keys__ == frozenset()

libs/sdk-py/uv.lock

@@ -301,7 +301,7 @@ wheels = [
 
 [[package]]
 name = "langgraph"
-version = "1.2.17"
+version = "1.2.16"
 source = { editable = "../langgraph" }
 dependencies = [
     { name = "langchain-core" },
@@ -525,7 +525,7 @@ requires-dist = [
     { name = "langchain-core", specifier = ">=1.4.0,<2" },
     { name = "langchain-protocol", specifier = ">=0.0.15" },
     { name = "orjson", specifier = ">=3.11.5" },
-    { name = "websockets", specifier = ">=14" },
+    { name = "websockets", specifier = ">=14,<17" },
 ]
 
 [package.metadata.requires-dev]