Skip to content

Commit 6496876

Browse files
fixed formatting
1 parent f689e4f commit 6496876

File tree

1 file changed

+10
-2
lines changed

1 file changed

+10
-2
lines changed

datadog_lambda/wrapper.py

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -235,10 +235,18 @@ def _before(self, event, context):
235235

236236
if config.trace_enabled:
237237
if config.data_streams_enabled:
238-
from datadog_lambda.tracing import extract_dd_json_data_from_message_attributes
238+
from datadog_lambda.tracing import (
239+
extract_dd_json_data_from_message_attributes,
240+
)
239241
from ddtrace.data_streams import set_consume_checkpoint
240-
dd_json_data, arn = extract_dd_json_data_from_message_attributes(event)
242+
243+
dd_json_data, arn = extract_dd_json_data_from_message_attributes(
244+
event
245+
)
241246
if dd_json_data:
247+
print(f"dd_json_data {dd_json_data}")
248+
print(f"event_source {event_source}")
249+
print(f"arn {arn}")
242250
carrier_get = lambda k: dd_json_data.get(k)
243251
set_consume_checkpoint(event_source, arn, carrier_get)
244252

0 commit comments

Comments
 (0)