Skip to content

Commit ac4e9cd

Browse files
linting
1 parent 8eaa42d commit ac4e9cd

File tree

2 files changed

+8
-4
lines changed

2 files changed

+8
-4
lines changed

datadog_lambda/wrapper.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,14 @@ def _before(self, event, context):
247247
print(f"dd_json_data {dd_json_data}")
248248
print(f"event_source {event_source}")
249249
print(f"arn {arn}")
250-
carrier_get = lambda k: dd_json_data.get(k)
250+
251+
def create_carrier_get(context_json):
252+
def carrier_get(key):
253+
return context_json.get(key)
254+
255+
return carrier_get
256+
257+
carrier_get = create_carrier_get(dd_json_data)
251258
set_consume_checkpoint(event_source, arn, carrier_get)
252259

253260
set_dd_trace_py_root(trace_context_source, config.merge_xray_traces)

tests/test_tracing.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -42,9 +42,6 @@
4242
service_mapping as global_service_mapping,
4343
propagator,
4444
emit_telemetry_on_exception_outside_of_handler,
45-
_create_carrier_get,
46-
extract_context_from_sqs_or_sns_event_or_context,
47-
extract_context_from_kinesis_event,
4845
)
4946

5047
from tests.utils import get_mock_context

0 commit comments

Comments
 (0)