feat(semantic-conentions-ai): move custom histogram buckets

Author: minimAluminiumalism

packages/opentelemetry-instrumentation-anthropic/opentelemetry/instrumentation/anthropic/__init__.py

@@ -587,10 +587,18 @@ def _instrument(self, **kwargs):
         tracer_provider = kwargs.get("tracer_provider")
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
-        # meter and counters are inited here
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
+        # meter and counters are inited here
         if is_metrics_enabled():
             (
                 token_histogram,

packages/opentelemetry-instrumentation-bedrock/opentelemetry/instrumentation/bedrock/__init__.py

@@ -575,10 +575,18 @@ def _instrument(self, **kwargs):
         tracer_provider = kwargs.get("tracer_provider")
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
-        # meter and counters are inited here
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
+        # meter and counters are inited here
         if is_metrics_enabled():
             (
                 token_histogram,

packages/opentelemetry-instrumentation-crewai/opentelemetry/instrumentation/crewai/instrumentation.py

@@ -25,6 +25,14 @@ def _instrument(self, **kwargs):
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
         if is_metrics_enabled():

packages/opentelemetry-instrumentation-groq/opentelemetry/instrumentation/groq/__init__.py

@@ -403,10 +403,18 @@ def _instrument(self, **kwargs):
         tracer_provider = kwargs.get("tracer_provider")
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
-        # meter and counters are inited here
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
+        # meter and counters are inited here
         if is_metrics_enabled():
             (
                 token_histogram,

packages/opentelemetry-instrumentation-langchain/opentelemetry/instrumentation/langchain/__init__.py

@@ -47,8 +47,15 @@ def _instrument(self, **kwargs):
         tracer_provider = kwargs.get("tracer_provider")
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
-        # Add meter creation
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
         # Create duration histogram

packages/opentelemetry-instrumentation-milvus/opentelemetry/instrumentation/milvus/__init__.py

@@ -87,6 +87,14 @@ def instrumentation_dependencies(self) -> Collection[str]:
     def _instrument(self, **kwargs):
         if is_metrics_enabled():
             meter_provider = kwargs.get("meter_provider")
+
+            if meter_provider is None:
+                try:
+                    from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                    apply_genai_bucket_configuration()
+                except ImportError:
+                    pass
+
             meter = get_meter(__name__, __version__, meter_provider)
 
             query_duration_metric = meter.create_histogram(

packages/opentelemetry-instrumentation-ollama/opentelemetry/instrumentation/ollama/__init__.py

@@ -453,6 +453,14 @@ def _instrument(self, **kwargs):
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
         if is_metrics_collection_enabled():

packages/opentelemetry-instrumentation-openai-agents/opentelemetry/instrumentation/openai_agents/__init__.py

@@ -42,6 +42,14 @@ def _instrument(self, **kwargs):
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
         if is_metrics_enabled():

packages/opentelemetry-instrumentation-openai/opentelemetry/instrumentation/openai/v0/__init__.py

@@ -36,6 +36,14 @@ def _instrument(self, **kwargs):
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
         if not Config.use_legacy_attributes:

packages/opentelemetry-instrumentation-openai/opentelemetry/instrumentation/openai/v1/__init__.py

@@ -70,8 +70,15 @@ def _instrument(self, **kwargs):
         tracer_provider = kwargs.get("tracer_provider")
         tracer = get_tracer(__name__, __version__, tracer_provider)
 
-        # meter and counters are inited here
         meter_provider = kwargs.get("meter_provider")
+
+        if meter_provider is None:
+            try:
+                from opentelemetry.semconv_ai import apply_genai_bucket_configuration
+                apply_genai_bucket_configuration()
+            except ImportError:
+                pass
+
         meter = get_meter(__name__, __version__, meter_provider)
 
         if not Config.use_legacy_attributes: