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 63e41cb commit e5a0903Copy full SHA for e5a0903
datadog_lambda/tracing.py
@@ -422,11 +422,10 @@ def extract_context_from_kinesis_event(event, lambda_context):
422
data_str = str_bytes.decode("ascii")
423
data_obj = json.loads(data_str)
424
dd_ctx = data_obj.get("_datadog")
425
- if dd_ctx:
426
- if idx == 0:
427
- context = propagator.extract(dd_ctx)
428
- if not config.data_streams_enabled:
429
- break
+ if dd_ctx and idx == 0:
+ context = propagator.extract(dd_ctx)
+ if not config.data_streams_enabled:
+ break
430
except Exception as e:
431
logger.debug("The trace extractor returned with error %s", e)
432
_dsm_set_checkpoint(dd_ctx, "kinesis", source_arn)
0 commit comments