Skip to content

Commit 6936bba

Browse files
keep APM record[0] implementation
1 parent 90480bb commit 6936bba

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

datadog_lambda/tracing.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -408,7 +408,9 @@ def extract_context_from_kinesis_event(event, lambda_context):
408408
source_arn = record.get("eventSourceARN", "")
409409
kinesis = record.get("kinesis")
410410
if not kinesis:
411-
return extract_context_from_lambda_context(lambda_context)
411+
if idx == 0:
412+
return extract_context_from_lambda_context(lambda_context)
413+
continue
412414
data = kinesis.get("data")
413415
if data:
414416
import base64

0 commit comments

Comments
 (0)