Skip to content

Commit e0a92b0

Browse files
committed
Fix forwarding of span and trace ids
1 parent 5c30e21 commit e0a92b0

File tree

2 files changed

+9
-0
lines changed

2 files changed

+9
-0
lines changed

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

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -343,6 +343,9 @@ def from_api_log_record(cls, record: APILogRecord) -> LogRecord:
343343
timestamp=record.timestamp,
344344
observed_timestamp=record.observed_timestamp,
345345
context=record.context,
346+
trace_id=record.trace_id,
347+
span_id=record.span_id,
348+
trace_flags=record.trace_flags,
346349
severity_text=record.severity_text,
347350
severity_number=record.severity_number,
348351
body=record.body,

opentelemetry-sdk/tests/logs/test_log_record.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -189,6 +189,9 @@ def test_log_record_from_api_log_record(self):
189189
timestamp=1,
190190
observed_timestamp=2,
191191
context=get_current(),
192+
trace_id=123,
193+
span_id=456,
194+
trace_flags=TraceFlags(0x01),
192195
severity_text="WARN",
193196
severity_number=SeverityNumber.WARN,
194197
body="a log line",
@@ -201,6 +204,9 @@ def test_log_record_from_api_log_record(self):
201204
self.assertEqual(record.timestamp, 1)
202205
self.assertEqual(record.observed_timestamp, 2)
203206
self.assertEqual(record.context, get_current())
207+
self.assertEqual(record.trace_id, 123)
208+
self.assertEqual(record.span_id, 456)
209+
self.assertEqual(record.trace_flags, TraceFlags(0x01))
204210
self.assertEqual(record.severity_text, "WARN")
205211
self.assertEqual(record.severity_number, SeverityNumber.WARN)
206212
self.assertEqual(record.body, "a log line")

0 commit comments

Comments
 (0)