Update

Author: hectorhdzg

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

@@ -257,18 +257,16 @@ def dropped_attributes(self) -> int:
         return 0
 
     @classmethod
-    def from_api_log_record(
-        cls,
-        *,
-        record: LogRecord,
-        resource: Resource,
-        instrumentation_scope: InstrumentationScope | None = None,
-    ) -> ReadWriteLogRecord:
-        return cls(
-            log_record=record,
-            resource=resource,
-            instrumentation_scope=instrumentation_scope,
+    def _from_api_log_record(
+        cls, api_log_record: LogRecord, logger: Logger, context: Context
+    ) -> "ReadWriteLogRecord":
+        # pylint:disable=protected-access
+        record = ReadWriteLogRecord(
+            log_record=api_log_record,
+            resource=logger._resource,
+            instrumentation_scope=logger._instrumentation_scope,
         )
+        return record
 
 
 class LogRecordProcessor(abc.ABC):
@@ -621,9 +619,7 @@ def emit(
             if not isinstance(record, ReadWriteLogRecord):
                 # pylint:disable=protected-access
                 writable_record = ReadWriteLogRecord._from_api_log_record(
-                    record=record,
-                    resource=self._resource,
-                    instrumentation_scope=self._instrumentation_scope,
+                    record, self, context
                 )
             else:
                 writable_record = record
@@ -639,10 +635,9 @@ def emit(
                 attributes=attributes,
                 event_name=event_name,
             )
-            writable_record = ReadWriteLogRecord.from_api_log_record(
-                record=log_record,
-                resource=self._resource,
-                instrumentation_scope=self._instrumentation_scope,
+            # pylint:disable=protected-access
+            writable_record = ReadWriteLogRecord._from_api_log_record(
+                log_record, self, context
             )
 
         self._multi_log_record_processor.on_emit(writable_record)

opentelemetry-sdk/tests/logs/test_log_record.py

@@ -15,17 +15,19 @@
 import json
 import unittest
 import warnings
+from unittest.mock import Mock
 
 from opentelemetry._logs import LogRecord, SeverityNumber
 from opentelemetry.attributes import BoundedAttributes
 from opentelemetry.context import get_current
-from opentelemetry.sdk._logs import (
+from opentelemetry.sdk._logs._internal import (
     LogDroppedAttributesWarning,
     LogLimits,
     ReadableLogRecord,
     ReadWriteLogRecord,
 )
 from opentelemetry.sdk.resources import Resource
+from opentelemetry.sdk.util.instrumentation import InstrumentationScope
 from opentelemetry.trace.span import TraceFlags
 
 
@@ -213,8 +215,16 @@ def test_log_record_from_api_log_record(self):
         )
 
         resource = Resource.create({})
+
+        # Create a mock logger with the required attributes
+        logger = Mock()
+        logger._resource = resource
+        logger._instrumentation_scope = InstrumentationScope("test")
+
+        context = get_current()
+
         record = ReadWriteLogRecord._from_api_log_record(
-            record=api_log_record, resource=resource
+            api_log_record, logger, context
         )
 
         self.assertEqual(record.log_record.timestamp, 1)