Removing LogData

Author: hectorhdzg

CHANGELOG.md

@@ -38,7 +38,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Set expected User-Agent in HTTP headers for grpc OTLP exporter
   ([#4658](https://github.com/open-telemetry/opentelemetry-python/pull/4658))
 - Remove LogData and extend SDK LogRecord to have instrumentation scope
-  ([#](https://github.com/open-telemetry/opentelemetry-python/pull/))
+  ([#4676](https://github.com/open-telemetry/opentelemetry-python/pull/4676))
 
 ## Version 1.34.0/0.55b0 (2025-06-04)
 

opentelemetry-sdk/src/opentelemetry/sdk/_logs/__init__.py

@@ -14,7 +14,6 @@
 
 
 from opentelemetry.sdk._logs._internal import (
-    LogData,
     LogDeprecatedInitWarning,
     LogDroppedAttributesWarning,
     Logger,
@@ -26,7 +25,6 @@
 )
 
 __all__ = [
-    "LogData",
     "Logger",
     "LoggerProvider",
     "LoggingHandler",

opentelemetry-sdk/src/opentelemetry/sdk/_logs/_internal/__init__.py

@@ -338,19 +338,6 @@ def dropped_attributes(self) -> int:
         return 0
 
 
-@deprecated(
-    "Use LogRecord. Since logs are not stable yet this WILL be removed in future releases."
-)
-class LogData:
-    def __init__(
-        self,
-        log_record: LogRecord,
-        instrumentation_scope: InstrumentationScope,
-    ):
-        self.log_record = log_record
-        self.instrumentation_scope = instrumentation_scope
-
-
 class LogRecordProcessor(abc.ABC):
     """Interface to hook the log record emitting action.
 
@@ -406,23 +393,7 @@ def add_log_record_processor(
 
     def on_emit(self, log_record: LogRecord) -> None:
         for lp in self._log_record_processors:
-            # Handle backward compatibility with processors that might expect LogData
-            import inspect
-
-            sig = inspect.signature(lp.on_emit)
-            param_name = (
-                list(sig.parameters.keys())[0] if sig.parameters else None
-            )
-
-            # Check if the processor expects LogData (backward compatibility)
-            if param_name and "log_data" in param_name.lower():
-                # Create LogData for backward compatibility
-                log_data = LogData(
-                    log_record, log_record.instrumentation_scope
-                )
-                lp.on_emit(log_data)
-            else:
-                lp.on_emit(log_record)
+            lp.on_emit(log_record)
 
     def shutdown(self) -> None:
         """Shutdown the log processors one by one"""
@@ -495,26 +466,7 @@ def _submit_and_wait(
             future.result()
 
     def on_emit(self, log_record: LogRecord):
-        # Handle backward compatibility with processors that might expect LogData
-        def _emit_with_compat(lp):
-            import inspect
-
-            sig = inspect.signature(lp.on_emit)
-            param_name = (
-                list(sig.parameters.keys())[0] if sig.parameters else None
-            )
-
-            # Check if the processor expects LogData (backward compatibility)
-            if param_name and "log_data" in param_name.lower():
-                # Create LogData for backward compatibility
-                log_data = LogData(
-                    log_record, log_record.instrumentation_scope
-                )
-                return lp.on_emit(log_data)
-            else:
-                return lp.on_emit(log_record)
-
-        self._submit_and_wait(lambda lp: lambda: _emit_with_compat(lp))
+        self._submit_and_wait(lambda lp: lp.on_emit, log_record)
 
     def shutdown(self):
         self._submit_and_wait(lambda lp: lp.shutdown)