We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9996fbb commit 8b0313bCopy full SHA for 8b0313b
datadog_lambda/tracing.py
@@ -65,20 +65,19 @@
65
DD_TRACE_JAVA_TRACE_ID_PADDING = "00000000"
66
HIGHER_64_BITS = "HIGHER_64_BITS"
67
LOWER_64_BITS = "LOWER_64_BITS"
68
+PROPAGATION_KEY_BASE_64 = "dd-pathway-ctx-base64"
69
70
71
def _dsm_set_checkpoint(context_json, event_type, arn):
- if not config.data_streams_enabled:
72
- return
73
-
74
if not isinstance(context_json, dict):
75
return
76
77
- from ddtrace.data_streams import PROPAGATION_KEY_BASE_64
78
79
if context_json and PROPAGATION_KEY_BASE_64 not in context_json:
80
81
+ if not config.data_streams_enabled:
+ return
+
82
try:
83
from ddtrace.data_streams import set_consume_checkpoint
84
0 commit comments