|
31 | 31 | ReadableLogRecord, |
32 | 32 | ReadWriteLogRecord, |
33 | 33 | ) |
34 | | -from opentelemetry.sdk.resources import Resource |
35 | 34 | from opentelemetry.sdk._shared_internal import BatchProcessor, DuplicateFilter |
36 | 35 | from opentelemetry.sdk.environment_variables import ( |
37 | 36 | OTEL_BLRP_EXPORT_TIMEOUT, |
38 | 37 | OTEL_BLRP_MAX_EXPORT_BATCH_SIZE, |
39 | 38 | OTEL_BLRP_MAX_QUEUE_SIZE, |
40 | 39 | OTEL_BLRP_SCHEDULE_DELAY, |
41 | 40 | ) |
| 41 | +from opentelemetry.sdk.resources import Resource |
42 | 42 |
|
43 | 43 | _DEFAULT_SCHEDULE_DELAY_MILLIS = 5000 |
44 | 44 | _DEFAULT_MAX_EXPORT_BATCH_SIZE = 512 |
@@ -126,7 +126,11 @@ def on_emit(self, log_record: ReadWriteLogRecord): |
126 | 126 | try: |
127 | 127 | # Convert ReadWriteLogRecord to ReadableLogRecord before exporting |
128 | 128 | # Note: resource should not be None at this point as it's set during Logger.emit() |
129 | | - resource = log_record.resource if log_record.resource is not None else Resource.create({}) |
| 129 | + resource = ( |
| 130 | + log_record.resource |
| 131 | + if log_record.resource is not None |
| 132 | + else Resource.create({}) |
| 133 | + ) |
130 | 134 | readable_log_record = ReadableLogRecord( |
131 | 135 | log_record=log_record.log_record, |
132 | 136 | resource=resource, |
@@ -203,7 +207,11 @@ def __init__( |
203 | 207 | def on_emit(self, log_record: ReadWriteLogRecord) -> None: |
204 | 208 | # Convert ReadWriteLogRecord to ReadableLogRecord before passing to BatchProcessor |
205 | 209 | # Note: resource should not be None at this point as it's set during Logger.emit() |
206 | | - resource = log_record.resource if log_record.resource is not None else Resource.create({}) |
| 210 | + resource = ( |
| 211 | + log_record.resource |
| 212 | + if log_record.resource is not None |
| 213 | + else Resource.create({}) |
| 214 | + ) |
207 | 215 | readable_log_record = ReadableLogRecord( |
208 | 216 | log_record=log_record.log_record, |
209 | 217 | resource=resource, |
|
0 commit comments