File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -51,6 +51,7 @@ def _dsm_set_kinesis_context(event):
51
51
52
52
def _set_dsm_context_for_record (record , type , arn ):
53
53
from ddtrace .data_streams import set_consume_checkpoint
54
+
54
55
try :
55
56
context_json = _get_dsm_context_from_lambda (record )
56
57
if not context_json :
@@ -94,7 +95,9 @@ def _get_dsm_context_from_lambda(message):
94
95
if "MessageAttributes" in parsed_body :
95
96
message_body = parsed_body
96
97
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
+ )
98
101
99
102
message_attributes = message_body .get ("MessageAttributes" ) or message_body .get (
100
103
"messageAttributes"
You can’t perform that action at this time.
0 commit comments