GenAI spec updates for langchain

instrumentation-genai/opentelemetry-instrumentation-langchain/CHANGELOG.md

@@ -8,4 +8,8 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 ## Unreleased
 
 - Added span support for genAI langchain llm invocation.
-  ([#3665](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3665))
+  ([#3665](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3665))
+- Align LangChain instrumentation with GenAI schema 1.37.0 and add unit coverage for updated metadata.
+  ([#3813](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3813))
+- Capture GenAI input/output messages on spans by default with opt-out control.
+  ([#3813](https://github.com/open-telemetry/opentelemetry-python-contrib/pull/3813))

instrumentation-genai/opentelemetry-instrumentation-langchain/pyproject.toml

@@ -26,8 +26,8 @@ classifiers = [
 ]
 dependencies = [
   "opentelemetry-api >= 1.31.0",
-  "opentelemetry-instrumentation ~= 0.57b0",
-  "opentelemetry-semantic-conventions ~= 0.57b0"
+  "opentelemetry-instrumentation ~= 0.58b0",
+  "opentelemetry-semantic-conventions ~= 0.58b0"
 ]
 
 [project.optional-dependencies]
@@ -53,4 +53,3 @@ include = [
 
 [tool.hatch.build.targets.wheel]
 packages = ["src/opentelemetry"]
-

instrumentation-genai/opentelemetry-instrumentation-langchain/src/opentelemetry/instrumentation/langchain/__init__.py

@@ -36,6 +36,7 @@
 ---
 """
 
+import os
 from typing import Any, Callable, Collection
 
 from langchain_core.callbacks import BaseCallbackHandler  # type: ignore
@@ -72,6 +73,7 @@ def _instrument(self, **kwargs: Any):
         Enable Langchain instrumentation.
         """
         tracer_provider = kwargs.get("tracer_provider")
+        capture_messages = self._resolve_capture_messages(kwargs)
         tracer = get_tracer(
             __name__,
             __version__,
@@ -81,6 +83,7 @@ def _instrument(self, **kwargs: Any):
 
         otel_callback_handler = OpenTelemetryLangChainCallbackHandler(
             tracer=tracer,
+            capture_messages=capture_messages,
         )
 
         wrap_function_wrapper(
@@ -95,6 +98,18 @@ def _uninstrument(self, **kwargs: Any):
         """
         unwrap("langchain_core.callbacks.base.BaseCallbackManager", "__init__")
 
+    def _resolve_capture_messages(self, kwargs: dict[str, Any]) -> bool:
+        if "capture_messages" in kwargs:
+            return bool(kwargs["capture_messages"])
+
+        env_value = os.getenv(
+            "OTEL_INSTRUMENTATION_LANGCHAIN_CAPTURE_MESSAGES"
+        )
+        if env_value is not None:
+            return env_value.lower() in ("1", "true", "yes", "on")
+
+        return True
+
 
 class _BaseCallbackManagerInitWrapper:
     """