chore: release main

.release-please-manifest.json

@@ -1,4 +1,4 @@
 {
-  ".": "0.26.0",
-  "adk": "0.26.0"
+  ".": "0.27.0",
+  "adk": "0.27.0"
 }

CHANGELOG.md

@@ -12,6 +12,23 @@
 
 * **tracing:** emit OTel metrics for async span queue depth, batch drain, and SGP export success/failure (HTTP status labels). Disable SDK-side recording with ``AGENTEX_TRACING_METRICS=0``.
 
+## 0.27.0 (2026-09-18)
+
+Full Changelog: [agentex-client-v0.26.0...agentex-client-v0.27.0](https://github.com/scaleapi/scale-agentex-python/compare/agentex-client-v0.26.0...agentex-client-v0.27.0)
+
+### Features
+
+* **adk:** make AgentEx client HTTP timeouts configurable by env var ([#510](https://github.com/scaleapi/scale-agentex-python/issues/510)) ([066105f](https://github.com/scaleapi/scale-agentex-python/commit/066105f3be55bc3213ebf6b1a9664ca3fb1cc31f))
+* **cli:** stamp global.agent.version from the image tag on helm deploys ([#504](https://github.com/scaleapi/scale-agentex-python/issues/504)) ([a90f622](https://github.com/scaleapi/scale-agentex-python/commit/a90f62281ef262011bbdeb27d684ebac2f193ad3))
+* **obs:** wire sgp-obs from the SDK for traces, metrics and logs ([#518](https://github.com/scaleapi/scale-agentex-python/issues/518)) ([d88fac6](https://github.com/scaleapi/scale-agentex-python/commit/d88fac6a0b3e572a6346106a615265b2354d1f79))
+* **registration:** report the agent's commit and source repo at registration ([#508](https://github.com/scaleapi/scale-agentex-python/issues/508)) ([94335d7](https://github.com/scaleapi/scale-agentex-python/commit/94335d71ece7bfff3ba684fe43991e4bd2397295))
+* **tracing:** stamp __commit_sha__ automatically when AGENT_COMMIT_SHA is set ([#507](https://github.com/scaleapi/scale-agentex-python/issues/507)) ([53ab900](https://github.com/scaleapi/scale-agentex-python/commit/53ab9007ab2a78528c38fe254929b92ccce740a3))
+
+
+### Reverts
+
+* **obs:** remove sgp-obs beta changes ([#522](https://github.com/scaleapi/scale-agentex-python/issues/522)) ([687ebfb](https://github.com/scaleapi/scale-agentex-python/commit/687ebfbf874e1feb01e102c7130cebb7f26e387a))
+
 ## 0.26.0 (2026-09-14)
 
 Full Changelog: [agentex-client-v0.25.0...agentex-client-v0.26.0](https://github.com/scaleapi/scale-agentex-python/compare/agentex-client-v0.25.0...agentex-client-v0.26.0)

adk/CHANGELOG.md

@@ -1,5 +1,18 @@
 # Changelog
 
+## 0.27.0 (2026-09-18)
+
+Full Changelog: [agentex-sdk-v0.26.0...agentex-sdk-v0.27.0](https://github.com/scaleapi/scale-agentex-python/compare/agentex-sdk-v0.26.0...agentex-sdk-v0.27.0)
+
+### Features
+
+* **obs:** wire sgp-obs from the SDK for traces, metrics and logs ([#518](https://github.com/scaleapi/scale-agentex-python/issues/518)) ([d88fac6](https://github.com/scaleapi/scale-agentex-python/commit/d88fac6a0b3e572a6346106a615265b2354d1f79))
+
+
+### Reverts
+
+* **obs:** remove sgp-obs beta changes ([#522](https://github.com/scaleapi/scale-agentex-python/issues/522)) ([687ebfb](https://github.com/scaleapi/scale-agentex-python/commit/687ebfbf874e1feb01e102c7130cebb7f26e387a))
+
 ## 0.26.0 (2026-09-14)
 
 Full Changelog: [agentex-sdk-v0.25.0...agentex-sdk-v0.26.0](https://github.com/scaleapi/scale-agentex-python/compare/agentex-sdk-v0.25.0...agentex-sdk-v0.26.0)

adk/pyproject.toml

@@ -4,7 +4,7 @@
 # (agentex/{__init__.py, _*.py, types/, resources/}) ships from the slim
 # sibling package `agentex-client` which is pinned as a runtime dep.
 name = "agentex-sdk"
-version = "0.26.0"
+version = "0.27.0"
 description = "Agent Development Kit (ADK) overlay for the Agentex API — FastACP server, Temporal workflows, LLM provider integrations, observability"
 license = "Apache-2.0"
 authors = [

pyproject.toml

@@ -3,7 +3,7 @@
 # overlay (formerly `src/agentex/lib/*`) now lives in `adk/` and ships
 # as the sibling `agentex-sdk` package — see `adk/pyproject.toml`.
 name = "agentex-client"
-version = "0.26.0"
+version = "0.27.0"
 description = "The official Python REST client for the Agentex API"
 dynamic = ["readme"]
 license = "Apache-2.0"

src/agentex/_version.py

@@ -1,4 +1,4 @@
 # File generated from our OpenAPI spec by Stainless. See CONTRIBUTING.md for details.
 
 __title__ = "agentex"
-__version__ = "0.26.0"  # x-release-please-version
+__version__ = "0.27.0"  # x-release-please-version

src/agentex/lib/adk/utils/_modules/client.py

@@ -1,3 +1,4 @@
+import os
 from typing import override
 
 import httpx
@@ -26,7 +27,50 @@ def auth_flow(self, request):
         yield request
 
 
+# HTTP timeouts for the AgentEx client, in seconds. Defaults match the SDK's
+# DEFAULT_TIMEOUT, so leaving these unset changes nothing.
+_TIMEOUT_ENV_DEFAULTS = {
+    "connect": ("AGENTEX_CLIENT_CONNECT_TIMEOUT_SECONDS", 5.0),
+    "read": ("AGENTEX_CLIENT_READ_TIMEOUT_SECONDS", 300.0),
+    "write": ("AGENTEX_CLIENT_WRITE_TIMEOUT_SECONDS", 300.0),
+    "pool": ("AGENTEX_CLIENT_POOL_TIMEOUT_SECONDS", 300.0),
+}
+
+
+def _timeout_from_env() -> httpx.Timeout:
+    """Build the client timeout from environment variables.
+
+    Read from ``os.environ`` rather than from ``EnvironmentVariables``. That model
+    is loaded by worker startup and by ``EnvAuth.auth_flow`` on every request, and
+    ``agentex.lib.adk.utils`` builds a client at import time, so a field added
+    there would make a malformed timeout break all three. Reading here keeps the
+    blast radius to the one value that is actually wrong.
+
+    The connect timeout is the one worth raising: an AgentEx backend accepts
+    connections serially, so connect latency grows with the number of callers and
+    the 5s default is reached when a few hundred are in flight.
+    """
+    values = {}
+    for field, (env_var, default) in _TIMEOUT_ENV_DEFAULTS.items():
+        raw = os.environ.get(env_var)
+        if raw is None or raw.strip() == "":
+            values[field] = default
+            continue
+        try:
+            values[field] = float(raw)
+        except ValueError as exc:
+            raise ValueError(f"{env_var} must be a number in seconds, got {raw!r}") from exc
+    return httpx.Timeout(**values)
+
+
 def create_async_agentex_client(**kwargs) -> AsyncAgentex:
+    """Create an AsyncAgentex client.
+
+    An explicit ``timeout=`` always wins; otherwise the timeout comes from the
+    AGENTEX_CLIENT_*_TIMEOUT_SECONDS environment variables.
+    """
+    if "timeout" not in kwargs:
+        kwargs["timeout"] = _timeout_from_env()
     client = AsyncAgentex(**kwargs)
     client._client.auth = EnvAuth()
     return client

src/agentex/lib/cli/handlers/deploy_handlers.py

@@ -389,6 +389,8 @@ def merge_deployment_configs(
             _deep_merge(helm_values, agent_env_config.helm_overrides)
         logger.info(f"After-merge helm values: {helm_values}")
 
+    _stamp_agent_version(helm_values, set(all_env_vars) | {var["name"] for var in secret_env_vars})
+
     # Set final environment variables
     # Environment variable precedence: manifest -> environments.yaml -> secrets (highest)
     if all_env_vars:
@@ -430,6 +432,14 @@ def _deep_merge(base_dict: dict[str, Any], override_dict: dict[str, Any]) -> Non
             base_dict[key] = value
 
 
+def _stamp_agent_version(helm_values: dict[str, Any], declared_env_names: set[str]) -> None:
+    """Set global.agent.version from the merged image tag unless the deployment declares AGENT_VERSION itself."""
+    if EnvVarKeys.AGENT_VERSION.value in declared_env_names:
+        # Chart >=0.6.0 renders global.agent.version as a second AGENT_VERSION env entry.
+        return
+    helm_values["global"]["agent"].setdefault("version", helm_values["global"]["image"]["tag"])
+
+
 def create_helm_values_file(helm_values: dict[str, Any]) -> str:
     """Create a temporary helm values file"""
     with tempfile.NamedTemporaryFile(mode="w", suffix=".yaml", delete=False) as f:

src/agentex/lib/core/tracing/code_revision.py

@@ -1,10 +1,11 @@
-"""Opt-in stamping of the agent's source commit onto its spans.
+"""Stamping of the agent's source commit onto its spans.
 
-Nothing is stamped until the agent calls :func:`enable`, mirroring the
-``lineage`` registry next door: a process-wide switch the agent sets once at
-import, rather than automatic behaviour every agent inherits. When enabled the
-resolved commit lands in span data under ``__commit_sha__`` and is searchable in
-the SGP Traces UI as ``__commit_sha__:<sha>``.
+Stamping turns on when the process starts with ``AGENT_COMMIT_SHA`` set, which
+the SGP cloud deploy does from the build record's attested commit, or when the
+agent calls :func:`enable` itself. Nothing is stamped otherwise: upgrading the
+SDK alone never starts emitting the field. When on, the resolved commit lands in
+span data under ``__commit_sha__`` and is searchable in the SGP Traces UI as
+``__commit_sha__:<sha>``.
 
 This is deliberately separate from ``__agent_version__``, which is automatic and
 carries the deployed image tag verbatim ("image tag or git sha"). That tag is a
@@ -21,7 +22,7 @@
 
 from agentex.lib.utils.logging import make_logger
 
-__all__ = ("COMMIT_SHA_KEY", "enable", "disable", "is_enabled", "commit_sha")
+__all__ = ("COMMIT_SHA_KEY", "enable", "disable", "is_enabled", "commit_sha", "is_git_object_name")
 
 logger = make_logger(__name__)
 
@@ -31,6 +32,12 @@
 # git's own 7-character minimum.
 _GIT_SHA_RE = re.compile(r"[0-9a-fA-F]{7,64}")
 
+
+def is_git_object_name(value: str) -> bool:
+    """Whether ``value`` is a full or abbreviated git SHA-1/SHA-256 object name."""
+    return _GIT_SHA_RE.fullmatch(value.strip()) is not None
+
+
 _COMMIT_SHA_ENV = "AGENT_COMMIT_SHA"
 # Fallback only: automatic, and only usable when it happens to be SHA-shaped.
 _AGENT_VERSION_ENV = "AGENT_VERSION"
@@ -42,13 +49,16 @@
 
 
 def enable(commit_sha: str | None = None) -> None:
-    """Opt this process in to stamping ``__commit_sha__`` onto every span.
+    """Turn on stamping ``__commit_sha__`` onto every span from this process.
 
     Value precedence: the explicit ``commit_sha`` argument, else
     ``AGENT_COMMIT_SHA``, else ``AGENT_VERSION`` when the deployment happened to
     set it to a bare commit SHA. A value that is not a git object name is
     refused with a warning and leaves stamping off -- better an absent field
     than one named for a commit that holds an image tag.
+
+    Called once at import when ``AGENT_COMMIT_SHA`` is set, so a deployment that
+    supplies the commit needs no code change in the agent.
     """
     global _commit_sha
 
@@ -103,3 +113,12 @@ def is_enabled() -> bool:
 def commit_sha() -> str | None:
     """The resolved commit SHA, or ``None`` when stamping is not enabled."""
     return _commit_sha
+
+
+def _enable_from_environment() -> None:
+    """Auto-enable on ``AGENT_COMMIT_SHA`` only; ``AGENT_VERSION`` stays an explicit fallback."""
+    if os.environ.get(_COMMIT_SHA_ENV, "").strip():
+        enable()
+
+
+_enable_from_environment()

src/agentex/lib/environment_variables.py

@@ -26,6 +26,7 @@ class EnvVarKeys(str, Enum):
     AGENT_ID = "AGENT_ID"
     AGENT_VERSION = "AGENT_VERSION"
     AGENT_COMMIT_SHA = "AGENT_COMMIT_SHA"
+    AGENT_SOURCE_REPO = "AGENT_SOURCE_REPO"
     AGENT_API_KEY = "AGENT_API_KEY"
     # ACP Configuration
     ACP_URL = "ACP_URL"
@@ -68,12 +69,11 @@ class EnvironmentVariables(BaseModel):
     AGENT_ID: str | None = None
     # Build/version discriminator (image tag or git sha), set by the deployment
     AGENT_VERSION: str | None = None
-    # The agent's source commit, baked into the image or set by the deployment.
-    # Unlike AGENT_VERSION this is expected to be a git SHA and nothing else, and
-    # it is OPT-IN: nothing is stamped unless the agent calls
-    # `adk.code_revision.enable()`, which also refuses a value that is not a git
-    # object name. See agentex.lib.core.tracing.code_revision.
+    # The agent's source commit, set by the deployment or baked into the image; a git
+    # SHA and nothing else. Stamped as __commit_sha__ when set (see tracing.code_revision).
     AGENT_COMMIT_SHA: str | None = None
+    # Git remote the agent was built from (any URL form; normalized to host/path on use).
+    AGENT_SOURCE_REPO: str | None = None
     AGENT_API_KEY: str | None = None
     ACP_TYPE: str | None = "async"
     AGENT_INPUT_TYPE: str | None = None

src/agentex/lib/utils/build_provenance.py

@@ -82,7 +82,8 @@ def normalize_remote(url: Optional[str]) -> Optional[str]:
     """Strip credentials and scheme from a remote, returning ``host/path``."""
     if not url:
         return None
-    candidate = url.strip()
+    # Query strings and fragments never name a repo, but they do carry tokens.
+    candidate = url.strip().split("?", 1)[0].split("#", 1)[0]
     # scp-like syntax: git@host:org/repo(.git) — no scheme, host/path split on ':'
     if "://" not in candidate and ":" in candidate and "/" not in candidate.split(":", 1)[0]:
         candidate = candidate.split("@", 1)[-1].replace(":", "/", 1)

src/agentex/lib/utils/registration.py

@@ -7,6 +7,8 @@
 
 from agentex.lib.utils.logging import make_logger
 from agentex.lib.environment_variables import EnvironmentVariables
+from agentex.lib.utils.build_provenance import normalize_remote
+from agentex.lib.core.tracing.code_revision import is_git_object_name
 
 logger = make_logger(__name__)
 
@@ -20,6 +22,29 @@ def get_auth_principal(env_vars: EnvironmentVariables):
     except Exception:
         return None
 
+
+def build_registration_metadata(env_vars: EnvironmentVariables, agent_card=None) -> dict:
+    """Deployment id, source provenance, and agent card; keys appear only when known."""
+    metadata: dict = {}
+    if env_vars.AGENTEX_DEPLOYMENT_ID:
+        metadata["deployment_id"] = env_vars.AGENTEX_DEPLOYMENT_ID
+    commit = (env_vars.AGENT_COMMIT_SHA or "").strip()
+    if commit:
+        if is_git_object_name(commit):
+            metadata["commit_sha"] = commit
+        else:
+            logger.warning(
+                "AGENT_COMMIT_SHA=%r is not a git commit SHA; commit_sha omitted from registration.",
+                commit,
+            )
+    repo = normalize_remote(env_vars.AGENT_SOURCE_REPO)
+    if repo:
+        metadata["source_repo"] = repo
+    if agent_card is not None:
+        metadata["agent_card"] = agent_card.model_dump() if hasattr(agent_card, "model_dump") else agent_card
+    return metadata
+
+
 async def register_agent(env_vars: EnvironmentVariables, agent_card=None):
     """Register this agent with the Agentex server"""
     if not env_vars.AGENTEX_BASE_URL:
@@ -33,13 +58,7 @@ async def register_agent(env_vars: EnvironmentVariables, agent_card=None):
         or f"Generic description for agent: {env_vars.AGENT_NAME}"
     )
 
-    # Registration metadata carries the deployment id and agent card.
-    registration_metadata: dict = {}
-    if env_vars.AGENTEX_DEPLOYMENT_ID:
-        registration_metadata["deployment_id"] = env_vars.AGENTEX_DEPLOYMENT_ID
-    if agent_card is not None:
-        card_data = agent_card.model_dump() if hasattr(agent_card, "model_dump") else agent_card
-        registration_metadata["agent_card"] = card_data
+    registration_metadata = build_registration_metadata(env_vars, agent_card)
 
     # Prepare registration data
     registration_data = {

tests/lib/cli/test_deploy_handlers.py

@@ -0,0 +1,64 @@
+"""Tests for the helm values merge_deployment_configs assembles for `agentex agents deploy`."""
+
+from __future__ import annotations
+
+from typing import Any
+
+from agentex.config.agent_config import AgentConfig
+from agentex.config.build_config import BuildConfig, BuildContext
+from agentex.config.agent_manifest import AgentManifest
+from agentex.config.deployment_config import ImageConfig, DeploymentConfig
+from agentex.config.environment_config import AgentAuthConfig, AgentEnvironmentConfig
+from agentex.lib.cli.handlers.deploy_handlers import InputDeployOverrides, merge_deployment_configs
+
+MANIFEST_TAG = "sha-manifest"
+
+
+def _manifest(env: dict[str, str] | None = None) -> AgentManifest:
+    return AgentManifest(
+        build=BuildConfig(context=BuildContext(root=".", dockerfile="Dockerfile", dockerignore=None)),
+        agent=AgentConfig(name="emu-tax", description="Files emu taxes", acp_type="async", env=env),
+        deployment=DeploymentConfig(image=ImageConfig(repository="registry.example.com/emu-tax", tag=MANIFEST_TAG)),
+    )
+
+
+def _env_config(helm_overrides: dict[str, Any]) -> AgentEnvironmentConfig:
+    return AgentEnvironmentConfig(auth=AgentAuthConfig(principal={"user_id": "u-1"}), helm_overrides=helm_overrides)
+
+
+def _merge(
+    manifest: AgentManifest,
+    env_config: AgentEnvironmentConfig | None = None,
+    image_tag: str | None = None,
+) -> dict[str, Any]:
+    overrides = InputDeployOverrides(image_tag=image_tag)
+    return merge_deployment_configs(manifest, env_config, overrides, "/nonexistent/manifest.yaml")
+
+
+class TestAgentVersion:
+    def test_stamped_from_the_deploy_image_tag(self):
+        values = _merge(_manifest(), image_tag="sha-cli")
+
+        assert values["global"]["agent"]["version"] == "sha-cli"
+
+    def test_follows_an_image_tag_overridden_in_helm_overrides(self):
+        values = _merge(_manifest(), _env_config({"global": {"image": {"tag": "sha-env"}}}))
+
+        assert values["global"]["image"]["tag"] == "sha-env"
+        assert values["global"]["agent"]["version"] == "sha-env"
+
+    def test_explicit_helm_override_of_the_version_wins(self):
+        values = _merge(_manifest(), _env_config({"global": {"agent": {"version": "pinned"}}}))
+
+        assert values["global"]["agent"]["version"] == "pinned"
+
+    def test_skipped_when_the_manifest_env_declares_agent_version(self):
+        values = _merge(_manifest(env={"AGENT_VERSION": "v1.2.3"}))
+
+        assert "version" not in values["global"]["agent"]
+        assert {"name": "AGENT_VERSION", "value": "v1.2.3"} in values["env"]
+
+    def test_skipped_when_the_environment_env_declares_agent_version(self):
+        values = _merge(_manifest(), _env_config({"env": [{"name": "AGENT_VERSION", "value": "v9"}]}))
+
+        assert "version" not in values["global"]["agent"]

tests/lib/core/tracing/processors/test_sgp_tracing_processor.py

@@ -56,13 +56,13 @@ def test_agent_identity_and_version_stamped_into_span_data(self):
 
     SHA = "b362b171a9c4e1f09d8e7a6b5c4d3e2f1a0b9c8d"
 
-    def test_commit_sha_is_not_stamped_without_opt_in(self, monkeypatch):
-        """Upgrading the SDK must not start emitting __commit_sha__ on its own,
-        even when the environment carries a perfectly good SHA."""
+    def test_commit_sha_is_not_stamped_when_env_absent(self, monkeypatch):
+        """Upgrading the SDK must not start emitting __commit_sha__ on its own;
+        only AGENT_COMMIT_SHA or an enable() call turns it on."""
         from agentex.lib.core.tracing import code_revision
         from agentex.lib.core.tracing.processors.sgp_tracing_processor import _sgp_metadata
 
-        monkeypatch.setenv("AGENT_COMMIT_SHA", self.SHA)
+        monkeypatch.delenv("AGENT_COMMIT_SHA", raising=False)
         code_revision.disable()
 
         span = _make_span(); span.data = {}