Skip to content

Commit b07528b

Browse files
formatting
1 parent 8318f22 commit b07528b

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

datadog_lambda/dsm.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@ def _dsm_set_kinesis_context(event):
5151

5252
def _set_dsm_context_for_record(record, type, arn):
5353
from ddtrace.data_streams import set_consume_checkpoint
54+
5455
try:
5556
context_json = _get_dsm_context_from_lambda(record)
5657
if not context_json:
@@ -94,7 +95,9 @@ def _get_dsm_context_from_lambda(message):
9495
if "MessageAttributes" in parsed_body:
9596
message_body = parsed_body
9697
except (ValueError, TypeError):
97-
logger.debug("Unable to parse lambda message body as JSON, treat as non-json")
98+
logger.debug(
99+
"Unable to parse lambda message body as JSON, treat as non-json"
100+
)
98101

99102
message_attributes = message_body.get("MessageAttributes") or message_body.get(
100103
"messageAttributes"

0 commit comments

Comments
 (0)