fix(hermes): align response id dependencies

Author: sipercai

instrumentation-loongsuite/loongsuite-instrumentation-hermes-agent/CHANGELOG.md

@@ -12,6 +12,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Prefer provider-supplied OpenAI-compatible response IDs (including
   DashScope-style `request_id` values) for `gen_ai.response.id` on Hermes LLM
   spans, while retaining Hermes's response ID as a fallback.
+- Align the Hermes plugin with the OpenTelemetry 1.39.1/0.60b1 release set used
+  by LoongSuite releases so its standard PyPI dependencies resolve consistently.
 
 ## Version 0.7.0 (2026-07-03)
 

instrumentation-loongsuite/loongsuite-instrumentation-hermes-agent/pyproject.toml

@@ -24,11 +24,11 @@ classifiers = [
   "Programming Language :: Python :: 3.13",
 ]
 dependencies = [
-  "opentelemetry-api >= 1.37.0, < 1.40",
-  "opentelemetry-instrumentation >= 0.60b1, < 0.61",
-  "opentelemetry-instrumentation-threading >= 0.60b1, < 0.61",
-  "opentelemetry-sdk >= 1.37.0, < 1.40",
-  "opentelemetry-semantic-conventions >= 0.60b1, < 0.61",
+  "opentelemetry-api ~= 1.39.1",
+  "opentelemetry-instrumentation ~= 0.60b1",
+  "opentelemetry-instrumentation-threading ~= 0.60b1",
+  "opentelemetry-sdk ~= 1.39.1",
+  "opentelemetry-semantic-conventions ~= 0.60b1",
   "opentelemetry-util-genai",
   "wrapt >= 1.0.0, < 2.0.0",
 ]

instrumentation-loongsuite/loongsuite-instrumentation-hermes-agent/src/opentelemetry/instrumentation/hermes_agent/wrappers.py

@@ -74,22 +74,30 @@ class _ProviderResponseAttempt:
     def __init__(self) -> None:
         self._lock = threading.Lock()
         self._response_id: str | None = None
+        self._response_id_priority = 0
 
     @property
     def response_id(self) -> str | None:
         with self._lock:
             return self._response_id
 
     def record(self, value: Any) -> None:
-        response_id = extract_response_id(
-            value,
-            fields=("request_id", "id", "response_id"),
-        )
+        # DashScope exposes its provider correlation ID as ``request_id`` even
+        # when an OpenAI-compatible completion ``id`` is also present.
+        response_id = extract_response_id(value, fields=("request_id",))
+        priority = 2
+        if response_id is None:
+            response_id = extract_response_id(
+                value,
+                fields=("id", "response_id"),
+            )
+            priority = 1
         if response_id is None:
             return
         with self._lock:
-            if self._response_id is None:
+            if priority > self._response_id_priority:
                 self._response_id = response_id
+                self._response_id_priority = priority
 
 
 class _ProviderResponseIdCapture:

instrumentation-loongsuite/loongsuite-instrumentation-hermes-agent/tests/requirements.txt

@@ -19,11 +19,11 @@ pyyaml>=6.0
 openai>=1.0.0
 wrapt>=1.0.0,<2.0.0
 
-opentelemetry-api>=1.37.0,<1.40
-opentelemetry-sdk>=1.37.0,<1.40
-opentelemetry-instrumentation>=0.60b1,<0.61
-opentelemetry-instrumentation-threading>=0.60b1,<0.61
-opentelemetry-semantic-conventions>=0.60b1,<0.61
+opentelemetry-api==1.39.1
+opentelemetry-sdk==1.39.1
+opentelemetry-instrumentation==0.60b1
+opentelemetry-instrumentation-threading==0.60b1
+opentelemetry-semantic-conventions==0.60b1
 
 -e util/opentelemetry-util-genai
 -e instrumentation-loongsuite/loongsuite-instrumentation-hermes-agent

instrumentation-loongsuite/loongsuite-instrumentation-hermes-agent/tests/test_telemetry_spec.py

@@ -512,7 +512,7 @@ def test_streaming_request_id_from_usage_trailer_is_preserved(
         [
             iter(
                 [
-                    _stream_chunk(),
+                    _stream_chunk("chatcmpl-chunk-456"),
                     _stream_chunk(request_id="dashscope-request-456"),
                 ]
             )

util/opentelemetry-util-genai/src/opentelemetry/util/genai/response_id.py

@@ -17,7 +17,7 @@
 from __future__ import annotations
 
 from collections.abc import Mapping, Sequence
-from typing import Any
+from typing import Any, cast
 
 
 def _normalize_response_id(value: Any) -> str | None:
@@ -46,11 +46,11 @@ def extract_response_id(
 
     for field in fields:
         try:
-            candidate = (
-                response.get(field)
-                if isinstance(response, Mapping)
-                else getattr(response, field, None)
-            )
+            if isinstance(response, Mapping):
+                mapping_response = cast(Mapping[str, Any], response)
+                candidate = mapping_response.get(field)
+            else:
+                candidate = getattr(response, field, None)
         except Exception:  # pylint: disable=broad-exception-caught
             # Provider SDK properties may raise arbitrary lazy-load errors;
             # response-ID telemetry must never break the model call.