botocore: document threading instrumentation for S3 multipart operations (open-telemetry#3999)

* botocore: document threading instrumentation for S3 multipart operations

Document that users need to enable ThreadingInstrumentor alongside
BotocoreInstrumentor for proper trace context propagation with S3
upload_file and download_file methods.

* botocore: move thread context docs to module docstring only

README.rst is not built into the documentation, so keep the
threading context propagation docs only in __init__.py where
autodoc will pick them up.

* Update __init__.py

* Update __init__.py

---------

Co-authored-by: Riccardo Magliocchetti <riccardo.magliocchetti@gmail.com>

Author: 2 people

instrumentation-genai/opentelemetry-instrumentation-google-genai/src/opentelemetry/instrumentation/google_genai/generate_content.py

@@ -21,6 +21,7 @@
 import os
 import time
 from typing import Any, AsyncIterator, Awaitable, Iterator, Optional, Union
+import collections.abc
 
 from google.genai.models import AsyncModels, Models
 from google.genai.models import t as transformers
@@ -44,6 +45,7 @@
     _OpenTelemetryStabilitySignalType,
     _StabilityMode,
 )
+from opentelemetry.instrumentation.utils import is_instrumentation_enabled
 from opentelemetry.semconv._incubating.attributes import (
     code_attributes,
     gen_ai_attributes,
@@ -708,6 +710,11 @@ def instrumented_generate_content(
         config: Optional[GenerateContentConfigOrDict] = None,
         **kwargs: Any,
     ) -> GenerateContentResponse:
+        if not is_instrumentation_enabled():
+            return wrapped_func(
+                self, model=model, contents=contents, config=config, **kwargs
+            )
+
         candidates = []
         helper = _GenerateContentInstrumentationHelper(
             self,
@@ -783,6 +790,11 @@ def instrumented_generate_content_stream(
         config: Optional[GenerateContentConfigOrDict] = None,
         **kwargs: Any,
     ) -> Iterator[GenerateContentResponse]:
+        if not is_instrumentation_enabled():
+            for resp in wrapped_func(self, model=model, contents=contents, config=config, **kwargs):
+                yield resp
+            return
+
         candidates: list[Candidate] = []
         helper = _GenerateContentInstrumentationHelper(
             self,
@@ -858,6 +870,10 @@ async def instrumented_generate_content(
         config: Optional[GenerateContentConfigOrDict] = None,
         **kwargs: Any,
     ) -> GenerateContentResponse:
+        if not is_instrumentation_enabled():
+            return await wrapped_func(
+                self, model=model, contents=contents, config=config, **kwargs
+            )
         helper = _GenerateContentInstrumentationHelper(
             self,
             otel_wrapper,
@@ -933,6 +949,9 @@ async def instrumented_generate_content_stream(
         config: Optional[GenerateContentConfigOrDict] = None,
         **kwargs: Any,
     ) -> Awaitable[AsyncIterator[GenerateContentResponse]]:  # type: ignore
+        if not is_instrumentation_enabled():
+            return await wrapped_func(self, model=model, contents=contents, config=config, **kwargs)
+
         helper = _GenerateContentInstrumentationHelper(
             self,
             otel_wrapper,

instrumentation-genai/opentelemetry-instrumentation-google-genai/src/opentelemetry/instrumentation/google_genai/tool_call_wrapper.py

@@ -29,6 +29,7 @@
     _OpenTelemetryStabilitySignalType,
     _StabilityMode,
 )
+from opentelemetry.instrumentation.utils import is_instrumentation_enabled
 from opentelemetry.semconv._incubating.attributes import (
     code_attributes,
 )
@@ -168,6 +169,9 @@ def _wrap_sync_tool_function(
 ):
     @functools.wraps(tool_function)
     def wrapped_function(*args, **kwargs):
+        if not is_instrumentation_enabled():
+            return tool_function(*args, **kwargs)
+
         span_name = _create_function_span_name(tool_function)
         attributes = _create_function_span_attributes(
             tool_function, args, kwargs, extra_span_attributes
@@ -193,6 +197,9 @@ def _wrap_async_tool_function(
 ):
     @functools.wraps(tool_function)
     async def wrapped_function(*args, **kwargs):
+        if not is_instrumentation_enabled():
+            return await tool_function(*args, **kwargs)
+
         span_name = _create_function_span_name(tool_function)
         attributes = _create_function_span_attributes(
             tool_function, args, kwargs, extra_span_attributes

instrumentation-genai/opentelemetry-instrumentation-google-genai/tests/generate_content/nonstreaming_base.py

@@ -20,6 +20,7 @@
 from google.genai.types import GenerateContentConfig
 from pydantic import BaseModel, Field
 
+from opentelemetry.instrumentation import utils
 from opentelemetry.instrumentation._semconv import (
     _OpenTelemetrySemanticConventionStability,
     _OpenTelemetryStabilitySignalType,
@@ -448,3 +449,14 @@ def test_records_metrics_data(self):
         self.otel.assert_has_metrics_data_named(
             "gen_ai.client.operation.duration"
         )
+
+    def test_suppress_instrumentation(self):
+        self.configure_valid_response(text="Yep, it works!")
+        with utils.suppress_instrumentation():
+            response = self.generate_content(
+                model="gemini-2.0-flash", contents="Does this work?"
+            )
+        self.assertEqual(response.text, "Yep, it works!")
+        self.otel.assert_does_not_have_span_named(
+            "generate_content gemini-2.0-flash"
+        )