@@ -269,7 +269,7 @@ def tearDown(self):
269269 @with_trace_propagation_style ("datadog" )
270270 def test_without_datadog_trace_headers (self ):
271271 lambda_ctx = get_mock_context ()
272- ctx , source , _ , _ = extract_dd_trace_context ({}, lambda_ctx )
272+ ctx , source , event_source , _ = extract_dd_trace_context ({}, lambda_ctx )
273273 self .assertEqual (source , "xray" )
274274 self .assertEqual (
275275 ctx ,
@@ -292,7 +292,7 @@ def test_without_datadog_trace_headers(self):
292292 @with_trace_propagation_style ("datadog" )
293293 def test_with_non_object_event (self ):
294294 lambda_ctx = get_mock_context ()
295- ctx , source , _ , _ = extract_dd_trace_context (b"" , lambda_ctx )
295+ ctx , source , event_source , _ = extract_dd_trace_context (b"" , lambda_ctx )
296296 self .assertEqual (source , "xray" )
297297 self .assertEqual (
298298 ctx ,
@@ -315,7 +315,7 @@ def test_with_non_object_event(self):
315315 @with_trace_propagation_style ("datadog" )
316316 def test_with_incomplete_datadog_trace_headers (self ):
317317 lambda_ctx = get_mock_context ()
318- ctx , source , _ , _ = extract_dd_trace_context (
318+ ctx , source , event_source , _ = extract_dd_trace_context (
319319 {"headers" : {TraceHeader .TRACE_ID : "123" }},
320320 lambda_ctx ,
321321 )
@@ -340,7 +340,7 @@ def test_with_incomplete_datadog_trace_headers(self):
340340 def common_tests_with_trace_context_extraction_injection (
341341 self , headers , event_containing_headers , lambda_context = get_mock_context ()
342342 ):
343- ctx , source , _ , _ = extract_dd_trace_context (
343+ ctx , source , event_source , _ = extract_dd_trace_context (
344344 event_containing_headers ,
345345 lambda_context ,
346346 )
@@ -393,7 +393,7 @@ def extractor_foo(event, context):
393393 return trace_id , parent_id , sampling_priority
394394
395395 lambda_ctx = get_mock_context ()
396- ctx , ctx_source , _ , _ = extract_dd_trace_context (
396+ ctx , ctx_source , event_source , _ = extract_dd_trace_context (
397397 {
398398 "foo" : {
399399 TraceHeader .TRACE_ID : "123" ,
@@ -627,7 +627,7 @@ def _test_step_function_trace_data_common(
627627 TraceHeader .TAGS : f"_dd.p.tid={ expected_tid } " ,
628628 }
629629
630- ctx , source , _ , _ = extract_dd_trace_context (event , lambda_ctx )
630+ ctx , source , event_source , _ = extract_dd_trace_context (event , lambda_ctx )
631631
632632 self .assertEqual (source , "event" )
633633 self .assertEqual (ctx , expected_context )
@@ -717,7 +717,7 @@ def test_step_function_trace_data_redrive(self):
717717
718718 @with_trace_propagation_style ("datadog" )
719719 def test_step_function_trace_data_lambda_root (self ):
720- """Test JSONata style step function trace data extraction with upstream Lambda. """
720+ """Test JSONata style step function trace data extraction where there's an upstream Lambda"""
721721 sfn_event = {
722722 "_datadog" : {
723723 "Execution" : {
@@ -1148,7 +1148,7 @@ def test_mixed_parent_context_when_merging(self):
11481148 # use the dd-trace trace-id and the x-ray parent-id
11491149 # This allows parenting relationships like dd-trace -> x-ray -> dd-trace
11501150 lambda_ctx = get_mock_context ()
1151- ctx , source , _ , _ = extract_dd_trace_context (
1151+ ctx , source , event_type , _ = extract_dd_trace_context (
11521152 {
11531153 "headers" : {
11541154 TraceHeader .TRACE_ID : "123" ,
@@ -1174,7 +1174,7 @@ def test_set_dd_trace_py_root_no_span_id(self):
11741174 os .environ ["_X_AMZN_TRACE_ID" ] = "Root=1-5e272390-8c398be037738dc042009320"
11751175
11761176 lambda_ctx = get_mock_context ()
1177- ctx , source , _ , _ = extract_dd_trace_context (
1177+ ctx , source , event_type , _ = extract_dd_trace_context (
11781178 {
11791179 "headers" : {
11801180 TraceHeader .TRACE_ID : "123" ,
0 commit comments