Skip to content

Commit 62d8b69

Browse files
committed
the extraction part of the simplification done by dd-trace-py side injection
1 parent b3f83df commit 62d8b69

1 file changed

Lines changed: 4 additions & 2 deletions

File tree

datadog_lambda/tracing.py

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131

3232
from ddtrace import patch
3333
from ddtrace import __version__ as ddtrace_version
34-
from ddtrace.propagation.http import HTTPPropagator
34+
from ddtrace.propagation.http import HTTPPropagator, _DatadogMultiHeader
3535
from ddtrace.trace import Context, Span, tracer
3636

3737
from datadog_lambda.config import config
@@ -565,7 +565,9 @@ def _extract_context_from_durable_checkpoint(operation):
565565
if not isinstance(result, dict):
566566
return None
567567

568-
return propagator.extract(result)
568+
# Checkpoints are written by dd-trace-py as x-datadog-* headers, so extract
569+
# directly and bypass DD_TRACE_PROPAGATION_STYLE_EXTRACT on purpose.
570+
return _DatadogMultiHeader._extract(result)
569571

570572

571573
def extract_context_from_durable_execution(event):

0 commit comments

Comments
 (0)