Convert to ReadWriteLogRecord before exporting

Author: hectorhdzg

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

@@ -175,7 +175,7 @@ class ReadableLogRecord:
 
     log_record: LogRecord
     resource: Resource
-    instrumentation_scope: InstrumentationScope
+    instrumentation_scope: InstrumentationScope | None = None
 
     @property
     def dropped_attributes(self) -> int:
@@ -293,7 +293,7 @@ def shutdown(self):
         """Called when a :class:`opentelemetry.sdk._logs.Logger` is shutdown"""
 
     @abc.abstractmethod
-    def force_flush(self, timeout_millis: int = 30000):
+    def force_flush(self, timeout_millis: int = 30000) -> bool:
         """Export all the received logs to the configured Exporter that have not yet
         been exported.
 

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

@@ -123,7 +123,13 @@ def on_emit(self, log_record: ReadWriteLogRecord):
             return
         token = attach(set_value(_SUPPRESS_INSTRUMENTATION_KEY, True))
         try:
-            self._exporter.export((log_record,))
+            # Convert ReadWriteLogRecord to ReadableLogRecord before exporting
+            readable_log_record = ReadableLogRecord(
+                log_record=log_record.log_record,
+                resource=log_record.resource,
+                instrumentation_scope=log_record.instrumentation_scope,
+            )
+            self._exporter.export((readable_log_record,))
         except Exception:  # pylint: disable=broad-exception-caught
             _logger.exception("Exception while exporting logs.")
         detach(token)
@@ -191,7 +197,13 @@ def __init__(
         )
 
     def on_emit(self, log_record: ReadWriteLogRecord) -> None:
-        return self._batch_processor.emit(log_record)
+        # Convert ReadWriteLogRecord to ReadableLogRecord before passing to BatchProcessor
+        readable_log_record = ReadableLogRecord(
+            log_record=log_record.log_record,
+            resource=log_record.resource,
+            instrumentation_scope=log_record.instrumentation_scope,
+        )
+        return self._batch_processor.emit(readable_log_record)
 
     def shutdown(self):
         return self._batch_processor.shutdown()