@@ -590,7 +590,7 @@ def extract_dd_trace_context(
590590 global dd_trace_context
591591 trace_context_source = None
592592 event_source = parse_event_source (event )
593- dsm_carrier = None
593+ dd_data = None
594594
595595 if extractor is not None :
596596 context = extract_context_custom_extractor (extractor , event , lambda_context )
@@ -599,13 +599,13 @@ def extract_dd_trace_context(
599599 event , lambda_context , event_source , decode_authorizer_context
600600 )
601601 elif event_source .equals (EventTypes .SNS ) or event_source .equals (EventTypes .SQS ):
602- context , dsm_carrier = extract_context_from_sqs_or_sns_event_or_context (
602+ context , dd_data = extract_context_from_sqs_or_sns_event_or_context (
603603 event , lambda_context
604604 )
605605 elif event_source .equals (EventTypes .EVENTBRIDGE ):
606606 context = extract_context_from_eventbridge_event (event , lambda_context )
607607 elif event_source .equals (EventTypes .KINESIS ):
608- context , dsm_carrier = extract_context_from_kinesis_event (event , lambda_context )
608+ context , dd_data = extract_context_from_kinesis_event (event , lambda_context )
609609 elif event_source .equals (EventTypes .STEPFUNCTIONS ):
610610 context = extract_context_from_step_functions (event , lambda_context )
611611 else :
@@ -622,7 +622,7 @@ def extract_dd_trace_context(
622622 if dd_trace_context :
623623 trace_context_source = TraceContextSource .XRAY
624624 logger .debug ("extracted dd trace context %s" , dd_trace_context )
625- return dd_trace_context , trace_context_source , event_source , dsm_carrier
625+ return dd_trace_context , trace_context_source , event_source , dd_data
626626
627627
628628def get_dd_trace_context_obj ():
0 commit comments