Skip to content

Commit 4ad2bab

Browse files
lambda functions not allowed by lint
1 parent c84ea14 commit 4ad2bab

File tree

1 file changed

+8
-1
lines changed

1 file changed

+8
-1
lines changed

datadog_lambda/tracing.py

Lines changed: 8 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,14 +77,21 @@ def _dsm_set_checkpoint(context_json, event_type, arn):
7777
try:
7878
from ddtrace.data_streams import set_consume_checkpoint
7979

80-
carrier_get = lambda k: context_json.get(k)
80+
carrier_get = _create_carrier_get(context_json)
8181
set_consume_checkpoint(event_type, arn, carrier_get, manual_checkpoint=False)
8282
except Exception as e:
8383
logger.debug(
8484
f"DSM:Failed to set consume checkpoint for {event_type} {arn}: {e}"
8585
)
8686

8787

88+
def _create_carrier_get(context_json):
89+
def carrier_get(key):
90+
return context_json.get(key)
91+
92+
return carrier_get
93+
94+
8895
def _convert_xray_trace_id(xray_trace_id):
8996
"""
9097
Convert X-Ray trace id (hex)'s last 63 bits to a Datadog trace id (int).

0 commit comments

Comments
 (0)