@@ -71,9 +71,9 @@ def _get_dd_trace_native_context():
7171 parent_id = span .context .span_id
7272 trace_id = span .context .trace_id
7373 return {
74- "parent_id " : str (parent_id ),
75- "trace_id " : str (trace_id ),
76- "sampling_priority " : SamplingPriority .AUTO_KEEP ,
74+ "parent-id " : str (parent_id ),
75+ "trace-id " : str (trace_id ),
76+ "sampling-priority " : SamplingPriority .AUTO_KEEP ,
7777 "source" : Source .DDTRACE ,
7878 }
7979
@@ -106,17 +106,17 @@ def extract_dd_trace_context(event):
106106 sampling_priority = lowercase_headers .get (TraceHeader .SAMPLING_PRIORITY )
107107 if trace_id and parent_id and sampling_priority :
108108 logger .debug ("Extracted Datadog trace context from headers" )
109- dd_trace_context = {
109+ metadata = {
110110 "trace-id" : trace_id ,
111111 "parent-id" : parent_id ,
112112 "sampling-priority" : sampling_priority ,
113- "source" : Source .EVENT ,
114113 }
115114 xray_recorder .begin_subsegment (XraySubsegment .NAME )
116115 subsegment = xray_recorder .current_subsegment ()
117- subsegment .put_metadata (
118- XraySubsegment .KEY , dd_trace_context , XraySubsegment .NAMESPACE
119- )
116+
117+ subsegment .put_metadata (XraySubsegment .KEY , metadata , XraySubsegment .NAMESPACE )
118+ dd_trace_context = metadata .copy ()
119+ dd_trace_context ["source" ] = Source .EVENT
120120 xray_recorder .end_subsegment ()
121121 else :
122122 # AWS Lambda runtime caches global variables between invocations,
0 commit comments