Add provider.name, rename client to handler

Author: keith-decker

util/opentelemetry-util-genai/pyproject.toml

@@ -25,9 +25,9 @@ classifiers = [
   "Programming Language :: Python :: 3.13",
 ]
 dependencies = [
-  "opentelemetry-instrumentation ~= 0.51b0",
-  "opentelemetry-semantic-conventions ~= 0.51b0",
-  "opentelemetry-api>=1.31.0",
+  "opentelemetry-instrumentation ~= 0.57b0",
+  "opentelemetry-semantic-conventions ~= 0.57b0",
+  "opentelemetry-api>=1.36.0",
 ]
 
 [project.optional-dependencies]

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

@@ -70,8 +70,9 @@ def _message_to_event(message, system, framework) -> Optional[Event]:
         body = {"content": content}
         attributes = {
             # TODO: add below to opentelemetry.semconv._incubating.attributes.gen_ai_attributes
+            "gen_ai.provider.name": system,  # Added in 1.37 - https://github.com/open-telemetry/semantic-conventions/blob/main/docs/registry/attributes/gen-ai.md#gen-ai-provider-name
             "gen_ai.framework": framework,
-            GenAI.GEN_AI_SYSTEM: system,
+            GenAI.GEN_AI_SYSTEM: system,  # Deprecated: Removed in 1.37
         }
 
         return Event(
@@ -88,8 +89,9 @@ def _chat_generation_to_event(
     if chat_generation.content:
         attributes = {
             # TODO: add below to opentelemetry.semconv._incubating.attributes.gen_ai_attributes
+            "gen_ai.provider.name": system,  # added in 1.37 - https://github.com/open-telemetry/semantic-conventions/blob/main/docs/registry/attributes/gen-ai.md#gen-ai-provider-name
             "gen_ai.framework": framework,
-            GenAI.GEN_AI_SYSTEM: system,
+            GenAI.GEN_AI_SYSTEM: system,  # Deprecated: removed in 1.37
         }
 
         message = {
@@ -121,7 +123,7 @@ def _get_metric_attributes(
         "gen_ai.framework": framework,
     }
     if system:
-        attributes[GenAI.GEN_AI_SYSTEM] = system
+        attributes["gen_ai.provider.name"] = system
     if operation_name:
         attributes[GenAI.GEN_AI_OPERATION_NAME] = operation_name
     if request_model:
@@ -243,7 +245,11 @@ def emit(self, invocation: LLMInvocation):
                 span.set_attribute("gen_ai.framework", framework)
 
             if system is not None:
-                span.set_attribute(GenAI.GEN_AI_SYSTEM, system)
+                span.set_attribute(
+                    GenAI.GEN_AI_SYSTEM, system
+                )  # Deprecated: use "gen_ai.provider.name"
+                # TODO: add below to opentelemetry.semconv._incubating.attributes.gen_ai_attributes
+                span.set_attribute("gen_ai.provider.name", system)
 
             finish_reasons = []
             for index, chat_generation in enumerate(
@@ -450,7 +456,11 @@ def emit(self, invocation: LLMInvocation):
                 span.set_attribute(
                     "gen_ai.framework", invocation.attributes.get("framework")
                 )
-            span.set_attribute(GenAI.GEN_AI_SYSTEM, system)
+            span.set_attribute(
+                GenAI.GEN_AI_SYSTEM, system
+            )  # Deprecated: use "gen_ai.provider.name"
+            # TODO: add below to opentelemetry.semconv._incubating.attributes.gen_ai_attributes
+            span.set_attribute("gen_ai.provider.name", system)
 
             finish_reasons = []
             for index, chat_generation in enumerate(

util/opentelemetry-util-genai/src/opentelemetry/util/genai/client.py renamed to util/opentelemetry-util-genai/src/opentelemetry/util/genai/handler.py

@@ -14,7 +14,7 @@
 
 import time
 from threading import Lock
-from typing import List, Optional
+from typing import Any, List, Optional
 from uuid import UUID
 
 from opentelemetry._events import get_event_logger
@@ -30,13 +30,13 @@
 from .version import __version__
 
 
-class TelemetryClient:
+class TelemetryHandler:
     """
-    High-level client managing GenAI invocation lifecycles and emitting
+    High-level handler managing GenAI invocation lifecycles and emitting
     them as spans, metrics, and events.
     """
 
-    def __init__(self, emitter_type_full: bool = True, **kwargs):
+    def __init__(self, emitter_type_full: bool = True, **kwargs: Any):
         tracer_provider = kwargs.get("tracer_provider")
         self._tracer = get_tracer(
             __name__,
@@ -79,8 +79,8 @@ def start_llm(
         prompts: List[Message],
         run_id: UUID,
         parent_run_id: Optional[UUID] = None,
-        **attributes,
-    ):
+        **attributes: Any,
+    ) -> None:
         invocation = LLMInvocation(
             messages=prompts,
             run_id=run_id,
@@ -95,7 +95,7 @@ def stop_llm(
         self,
         run_id: UUID,
         chat_generations: List[ChatGeneration],
-        **attributes,
+        **attributes: Any,
     ) -> LLMInvocation:
         with self._lock:
             invocation = self._llm_registry.pop(run_id)
@@ -106,7 +106,7 @@ def stop_llm(
         return invocation
 
     def fail_llm(
-        self, run_id: UUID, error: Error, **attributes
+        self, run_id: UUID, error: Error, **attributes: Any
     ) -> LLMInvocation:
         with self._lock:
             invocation = self._llm_registry.pop(run_id)
@@ -117,28 +117,28 @@ def fail_llm(
 
 
 # Singleton accessor
-_default_client: TelemetryClient | None = None
+_default_handler: Optional[TelemetryHandler] = None
 
 
-def get_telemetry_client(
-    emitter_type_full: bool = True, **kwargs
-) -> TelemetryClient:
-    global _default_client
-    if _default_client is None:
-        _default_client = TelemetryClient(
+def get_telemetry_handler(
+    emitter_type_full: bool = True, **kwargs: Any
+) -> TelemetryHandler:
+    global _default_handler
+    if _default_handler is None:
+        _default_handler = TelemetryHandler(
             emitter_type_full=emitter_type_full, **kwargs
         )
-    return _default_client
+    return _default_handler
 
 
 # Module‐level convenience functions
 def llm_start(
     prompts: List[Message],
     run_id: UUID,
     parent_run_id: Optional[UUID] = None,
-    **attributes,
-):
-    return get_telemetry_client().start_llm(
+    **attributes: Any,
+) -> None:
+    return get_telemetry_handler().start_llm(
         prompts=prompts,
         run_id=run_id,
         parent_run_id=parent_run_id,
@@ -147,14 +147,14 @@ def llm_start(
 
 
 def llm_stop(
-    run_id: UUID, chat_generations: List[ChatGeneration], **attributes
+    run_id: UUID, chat_generations: List[ChatGeneration], **attributes: Any
 ) -> LLMInvocation:
-    return get_telemetry_client().stop_llm(
+    return get_telemetry_handler().stop_llm(
         run_id=run_id, chat_generations=chat_generations, **attributes
     )
 
 
-def llm_fail(run_id: UUID, error: Error, **attributes) -> LLMInvocation:
-    return get_telemetry_client().fail_llm(
+def llm_fail(run_id: UUID, error: Error, **attributes: Any) -> LLMInvocation:
+    return get_telemetry_handler().fail_llm(
         run_id=run_id, error=error, **attributes
     )