File tree Expand file tree Collapse file tree 1 file changed +3
-15
lines changed Expand file tree Collapse file tree 1 file changed +3
-15
lines changed Original file line number Diff line number Diff line change @@ -300,11 +300,7 @@ def extract_context_from_sqs_or_sns_event_or_context(
300
300
"Failed to extract Step Functions context from SQS/SNS event."
301
301
)
302
302
context = propagator .extract (dd_data )
303
- _dsm_set_checkpoint (
304
- dd_data ,
305
- event_type ,
306
- source_arn ,
307
- )
303
+ _dsm_set_checkpoint (dd_data , event_type , source_arn )
308
304
return context
309
305
else :
310
306
# Handle case where trace context is injected into attributes.AWSTraceHeader
@@ -329,20 +325,12 @@ def extract_context_from_sqs_or_sns_event_or_context(
329
325
sampling_priority = float (x_ray_context ["sampled" ]),
330
326
)
331
327
# Still want to set a DSM checkpoint even if DSM context not propagated
332
- _dsm_set_checkpoint (
333
- None ,
334
- event_type ,
335
- source_arn ,
336
- )
328
+ _dsm_set_checkpoint (None , event_type , source_arn )
337
329
return extract_context_from_lambda_context (lambda_context )
338
330
except Exception as e :
339
331
logger .debug ("The trace extractor returned with error %s" , e )
340
332
# Still want to set a DSM checkpoint even if DSM context not propagated
341
- _dsm_set_checkpoint (
342
- None ,
343
- event_type ,
344
- source_arn ,
345
- )
333
+ _dsm_set_checkpoint (None , event_type , source_arn )
346
334
return extract_context_from_lambda_context (lambda_context )
347
335
348
336
You can’t perform that action at this time.
0 commit comments