22# Licensed under the MIT License.
33import json
44import logging
5- from typing import Optional , Sequence , Any , Union
5+ from typing import Optional , Sequence , Any
66
77from opentelemetry ._logs .severity import SeverityNumber
88from opentelemetry .semconv .attributes .exception_attributes import (
@@ -63,7 +63,7 @@ def export(self, batch: Sequence[LogData], **kwargs: Any) -> LogExportResult: #
6363 :return: The result of the export.
6464 :rtype: ~opentelemetry.sdk._logs.export.LogData
6565 """
66- envelopes = [envelope for log in batch if ( envelope := self ._log_to_envelope (log )) is not None ]
66+ envelopes = [self ._log_to_envelope (log ) for log in batch ]
6767 try :
6868 result = self ._transmit (envelopes )
6969 self ._handle_transmit_from_storage (envelopes , result )
@@ -80,10 +80,8 @@ def shutdown(self) -> None:
8080 if self .storage :
8181 self .storage .close ()
8282
83- def _log_to_envelope (self , log_data : LogData ) -> Union [ TelemetryItem , None ] :
83+ def _log_to_envelope (self , log_data : LogData ) -> TelemetryItem :
8484 envelope = _convert_log_to_envelope (log_data )
85- if envelope is None :
86- return None
8785 envelope .instrumentation_key = self ._instrumentation_key
8886 return envelope
8987
@@ -117,7 +115,7 @@ def _log_data_is_event(log_data: LogData) -> bool:
117115
118116
119117# pylint: disable=protected-access
120- def _convert_log_to_envelope (log_data : LogData ) -> Union [ TelemetryItem , None ] :
118+ def _convert_log_to_envelope (log_data : LogData ) -> TelemetryItem :
121119 log_record = log_data .log_record
122120 time_stamp = log_record .timestamp if log_record .timestamp is not None else log_record .observed_timestamp
123121 envelope = _utils ._create_telemetry_item (time_stamp )
@@ -191,9 +189,6 @@ def _convert_log_to_envelope(log_data: LogData) -> Union[TelemetryItem, None]:
191189 severity_level = severity_level , # type: ignore
192190 properties = properties ,
193191 )
194- if len (data .message ) == 0 :
195- _logger .warning ("Log record body cannot be empty. Skipping export for this log record." )
196- return None
197192 envelope .data = MonitorBase (base_data = data , base_type = "MessageData" )
198193
199194 return envelope
0 commit comments