fix: resolve CI failures (lint, format, typecheck, changelog)

- Add # noqa: PLC0415 for intentional in-function imports in dashscope and hermes-agent
- Fix unsorted imports (I001) in loongsuite-distro
- Remove unnecessary # type: ignore comments in vertexai/patch.py
- Apply ruff format to all affected files
- Add CHANGELOG-loongsuite.md entry for semconv changes

Change-Id: Ibb440bd9e057fa82a91710db85380311d11a8c86
Co-developed-by: Qoder <noreply@qoder.com>

Author: 123liuziming

CHANGELOG-loongsuite.md

@@ -11,6 +11,10 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## Unreleased
 
+### Changed
+
+- Adopt upstream semantic conventions for LoongSuite instrumentation packages.
+
 ## Version 0.5.0 (2026-05-11)
 
 ### Fixed

instrumentation-genai/opentelemetry-instrumentation-vertexai/src/opentelemetry/instrumentation/vertexai/patch.py

@@ -173,7 +173,7 @@ def handle_response(
                 | None,
             ) -> None:
                 attributes = (
-                    get_server_attributes(instance.api_endpoint)  # type: ignore[reportUnknownMemberType]
+                    get_server_attributes(instance.api_endpoint)
                     | request_attributes
                     | get_genai_response_attributes(response)
                 )
@@ -257,7 +257,7 @@ def _with_default_instrumentation(
         kwargs: Any,
     ):
         params = _extract_params(*args, **kwargs)
-        api_endpoint: str = instance.api_endpoint  # type: ignore[reportUnknownMemberType]
+        api_endpoint: str = instance.api_endpoint
         span_attributes = {
             **get_genai_request_attributes(False, params),
             **get_server_attributes(api_endpoint),

instrumentation-loongsuite/loongsuite-instrumentation-claude-agent-sdk/src/opentelemetry/instrumentation/claude_agent_sdk/__init__.py

@@ -102,15 +102,14 @@ def _instrument(self, **kwargs: Any) -> None:
             wrap_function_wrapper(
                 module="claude_agent_sdk",
                 name="ClaudeSDKClient.__init__",
-                wrapper=lambda wrapped,
-                instance,
-                args,
-                kwargs: wrap_claude_client_init(
-                    wrapped,
-                    instance,
-                    args,
-                    kwargs,
-                    handler=ClaudeAgentSDKInstrumentor._handler,
+                wrapper=lambda wrapped, instance, args, kwargs: (
+                    wrap_claude_client_init(
+                        wrapped,
+                        instance,
+                        args,
+                        kwargs,
+                        handler=ClaudeAgentSDKInstrumentor._handler,
+                    )
                 ),
             )
         except Exception as e:
@@ -122,15 +121,14 @@ def _instrument(self, **kwargs: Any) -> None:
             wrap_function_wrapper(
                 module="claude_agent_sdk",
                 name="ClaudeSDKClient.query",
-                wrapper=lambda wrapped,
-                instance,
-                args,
-                kwargs: wrap_claude_client_query(
-                    wrapped,
-                    instance,
-                    args,
-                    kwargs,
-                    handler=ClaudeAgentSDKInstrumentor._handler,
+                wrapper=lambda wrapped, instance, args, kwargs: (
+                    wrap_claude_client_query(
+                        wrapped,
+                        instance,
+                        args,
+                        kwargs,
+                        handler=ClaudeAgentSDKInstrumentor._handler,
+                    )
                 ),
             )
         except Exception as e:
@@ -140,15 +138,14 @@ def _instrument(self, **kwargs: Any) -> None:
             wrap_function_wrapper(
                 module="claude_agent_sdk",
                 name="ClaudeSDKClient.receive_response",
-                wrapper=lambda wrapped,
-                instance,
-                args,
-                kwargs: wrap_claude_client_receive_response(
-                    wrapped,
-                    instance,
-                    args,
-                    kwargs,
-                    handler=ClaudeAgentSDKInstrumentor._handler,
+                wrapper=lambda wrapped, instance, args, kwargs: (
+                    wrap_claude_client_receive_response(
+                        wrapped,
+                        instance,
+                        args,
+                        kwargs,
+                        handler=ClaudeAgentSDKInstrumentor._handler,
+                    )
                 ),
             )
         except Exception as e:

instrumentation-loongsuite/loongsuite-instrumentation-claw-eval/src/opentelemetry/instrumentation/claw_eval/internal/wrappers.py

@@ -62,6 +62,7 @@
 # string instead of reading it from ``gen_ai_attributes``.
 GEN_AI_TOOL_DEFINITIONS = "gen_ai.tool.definitions"
 
+
 def _infer_provider_name(provider: Any) -> str:
     """Infer gen_ai.provider.name from the provider instance."""
     if provider is None:
@@ -89,7 +90,6 @@ def _infer_provider_name(provider: Any) -> str:
     return "openai"
 
 
-
 # ---------------------------------------------------------------------------
 # ContextVars for STEP lifecycle & compact-depth tracking
 # ---------------------------------------------------------------------------
@@ -545,9 +545,7 @@ def __call__(self, wrapped, instance, args, kwargs):
             # Set gen_ai.provider.name (Required attribute)
             _provider_name = _infer_provider_name(provider)
             if _provider_name:
-                span.set_attribute(
-                    GenAI.GEN_AI_PROVIDER_NAME, _provider_name
-                )
+                span.set_attribute(GenAI.GEN_AI_PROVIDER_NAME, _provider_name)
 
             model_id = ""
             if provider is not None:

instrumentation-loongsuite/loongsuite-instrumentation-dashscope/src/opentelemetry/instrumentation/dashscope/utils/common.py

@@ -88,7 +88,9 @@ def _extract_usage(response: Any) -> tuple[Optional[int], Optional[int]]:
         return None, None
 
 
-def _extract_cache_tokens(response: Any) -> tuple[Optional[int], Optional[int]]:
+def _extract_cache_tokens(
+    response: Any,
+) -> tuple[Optional[int], Optional[int]]:
     """Extract cache token usage from DashScope response.
 
     Args:
@@ -106,10 +108,9 @@ def _extract_cache_tokens(response: Any) -> tuple[Optional[int], Optional[int]]:
             return None, None
 
         # DashScope may report cache tokens in various fields
-        cache_creation = (
-            getattr(usage, "cache_creation_input_tokens", None)
-            or getattr(usage, "cache_creation_tokens", None)
-        )
+        cache_creation = getattr(
+            usage, "cache_creation_input_tokens", None
+        ) or getattr(usage, "cache_creation_tokens", None)
         cache_read = (
             getattr(usage, "cache_read_input_tokens", None)
             or getattr(usage, "cache_read_tokens", None)

instrumentation-loongsuite/loongsuite-instrumentation-dashscope/src/opentelemetry/instrumentation/dashscope/utils/generation.py

@@ -571,7 +571,8 @@ def _update_invocation_from_response(
         invocation.output_tokens = output_tokens
 
         # Extract cache token usage
-        from ..utils.common import _extract_cache_tokens
+        from ..utils.common import _extract_cache_tokens  # noqa: PLC0415
+
         cache_creation, cache_read = _extract_cache_tokens(response)
         if cache_creation is not None:
             invocation.usage_cache_creation_input_tokens = cache_creation

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

@@ -617,7 +617,7 @@ def _extract_server_info(instance: Any) -> tuple[str | None, int | None]:
         return None, None
     base_url_str = str(base_url).rstrip("/")
     try:
-        from urllib.parse import urlparse
+        from urllib.parse import urlparse  # noqa: PLC0415
 
         parsed = urlparse(base_url_str)
         address = parsed.hostname
@@ -703,14 +703,17 @@ def update_llm_invocation_from_response(
             if cached and cached > 0:
                 invocation.usage_cache_read_input_tokens = cached
         # Direct fields (some providers)
-        cache_creation = (
-            getattr(usage, "cache_creation_input_tokens", None)
-            or getattr(usage, "cache_creation_tokens", None)
-        )
+        cache_creation = getattr(
+            usage, "cache_creation_input_tokens", None
+        ) or getattr(usage, "cache_creation_tokens", None)
         if cache_creation and cache_creation > 0:
             invocation.usage_cache_creation_input_tokens = cache_creation
         cache_read = getattr(usage, "cache_read_input_tokens", None)
-        if cache_read and cache_read > 0 and not invocation.usage_cache_read_input_tokens:
+        if (
+            cache_read
+            and cache_read > 0
+            and not invocation.usage_cache_read_input_tokens
+        ):
             invocation.usage_cache_read_input_tokens = cache_read
 
     return input_tokens, output_tokens, total_tokens

instrumentation-loongsuite/loongsuite-instrumentation-litellm/src/opentelemetry/instrumentation/litellm/_wrapper.py

@@ -94,10 +94,8 @@ def __call__(self, *args, **kwargs):
                     callback=None,
                     invocation=invocation,
                 )
-                stream_wrapper.callback = (
-                    lambda span,
-                    last_chunk,
-                    error: self._handle_stream_end_with_handler(
+                stream_wrapper.callback = lambda span, last_chunk, error: (
+                    self._handle_stream_end_with_handler(
                         invocation, last_chunk, error, stream_wrapper
                     )
                 )
@@ -240,10 +238,8 @@ async def __call__(self, *args, **kwargs):
                     callback=None,
                     invocation=invocation,
                 )
-                stream_wrapper.callback = (
-                    lambda span,
-                    last_chunk,
-                    error: self._handle_stream_end_with_handler(
+                stream_wrapper.callback = lambda span, last_chunk, error: (
+                    self._handle_stream_end_with_handler(
                         invocation, last_chunk, error, stream_wrapper
                     )
                 )

instrumentation-loongsuite/loongsuite-instrumentation-minisweagent/src/opentelemetry/instrumentation/minisweagent/internal/agent_wrappers.py

@@ -113,7 +113,8 @@ def __call__(
             han.start_entry(entry_inv, context=context_api.get_current())
 
         inv = InvokeAgentInvocation(
-            provider="minisweagent", agent_name=agent_name,
+            provider="minisweagent",
+            agent_name=agent_name,
             agent_id=agent_name,
         )
         inv.request_model = _request_model_from_agent(instance)

instrumentation-loongsuite/loongsuite-instrumentation-vita/src/opentelemetry/instrumentation/vita/patch.py

@@ -354,7 +354,9 @@ def wrap_generate_next_message(
                         invocation.usage_cache_read_input_tokens = cached
                 cache_creation = usage.get("cache_creation_input_tokens")
                 if cache_creation and cache_creation > 0:
-                    invocation.usage_cache_creation_input_tokens = cache_creation
+                    invocation.usage_cache_creation_input_tokens = (
+                        cache_creation
+                    )
 
             handler.stop_invoke_agent(invocation)
             return result
@@ -409,7 +411,9 @@ def wrap_generate(
             invocation.response_model_name = model
 
             # response_id
-            resp_id = getattr(result, "id", None) or getattr(result, "response_id", None)
+            resp_id = getattr(result, "id", None) or getattr(
+                result, "response_id", None
+            )
             if resp_id:
                 invocation.response_id = str(resp_id)
 
@@ -432,7 +436,9 @@ def wrap_generate(
                         invocation.usage_cache_read_input_tokens = cached
                 cache_creation = usage.get("cache_creation_input_tokens")
                 if cache_creation and cache_creation > 0:
-                    invocation.usage_cache_creation_input_tokens = cache_creation
+                    invocation.usage_cache_creation_input_tokens = (
+                        cache_creation
+                    )
 
         handler.stop_llm(invocation)
         return result