Skip to content

Commit 3b47b39

Browse files
committed
Add metadata to track X-Ray segments
1 parent 8d6fbfd commit 3b47b39

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

datadog_lambda/tracing.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -233,7 +233,9 @@ def set_dd_trace_py_root(trace_context, merge_xray_traces):
233233
tracer.context_provider.activate(span_context)
234234

235235

236-
def create_function_execution_span(context, function_name, is_cold_start):
236+
def create_function_execution_span(
237+
context, function_name, is_cold_start, trace_context
238+
):
237239
tags = {}
238240
if context:
239241
tags = {
@@ -242,6 +244,10 @@ def create_function_execution_span(context, function_name, is_cold_start):
242244
"request_id": context.aws_request_id,
243245
"resource_names": context.function_name,
244246
}
247+
source = trace_context["source"]
248+
if source != TraceContextSource.DDTRACE:
249+
tags["_dd.parent_source"] = source
250+
245251
args = {
246252
"service": "aws.lambda",
247253
"resource": function_name,

datadog_lambda/wrapper.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -123,11 +123,10 @@ def _before(self, event, context):
123123
dd_context = extract_dd_trace_context(event)
124124

125125
self.span = None
126-
127126
if dd_tracing_enabled:
128127
set_dd_trace_py_root(dd_context, self.merge_xray_traces)
129128
self.span = create_function_execution_span(
130-
context, self.function_name, is_cold_start()
129+
context, self.function_name, is_cold_start(), dd_context
131130
)
132131
else:
133132
set_correlation_ids()

0 commit comments

Comments
 (0)