Skip to content

Commit 8c6a2e7

Browse files
committed
adjust the sequence of extraction logic so that event headers/request takes higher priority than the durable checkpoints
1 parent 6568d02 commit 8c6a2e7

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

datadog_lambda/tracing.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -638,8 +638,6 @@ def extract_dd_trace_context(
638638

639639
if extractor is not None:
640640
context = extract_context_custom_extractor(extractor, event, lambda_context)
641-
elif isinstance(event, dict) and "DurableExecutionArn" in event:
642-
context = extract_context_from_durable_execution(event)
643641
elif isinstance(event, (set, dict)) and "request" in event:
644642
context = extract_context_from_request_header_or_context(
645643
event, lambda_context, event_source
@@ -658,6 +656,8 @@ def extract_dd_trace_context(
658656
context = extract_context_from_kinesis_event(event, lambda_context)
659657
elif event_source.equals(EventTypes.STEPFUNCTIONS):
660658
context = extract_context_from_step_functions(event, lambda_context)
659+
elif isinstance(event, dict) and "DurableExecutionArn" in event:
660+
context = extract_context_from_durable_execution(event)
661661
else:
662662
context = extract_context_from_lambda_context(lambda_context)
663663

0 commit comments

Comments
 (0)