File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -221,7 +221,7 @@ def extract_context_from_sqs_or_sns_event_or_context(event, lambda_context):
221221 try :
222222 context = _extract_context_from_eventbridge_sqs_event (event )
223223 if _is_context_complete (context ):
224- return context , None
224+ return context , data_streams_ctx . get
225225 except Exception :
226226 logger .debug ("Failed extracting context as EventBridge to SQS." )
227227
@@ -279,7 +279,7 @@ def extract_context_from_sqs_or_sns_event_or_context(event, lambda_context):
279279 try :
280280 return (
281281 extract_context_from_step_functions (dd_data , None ),
282- None ,
282+ data_streams_ctx . get ,
283283 )
284284 except Exception :
285285 logger .debug (
@@ -309,12 +309,12 @@ def extract_context_from_sqs_or_sns_event_or_context(event, lambda_context):
309309 span_id = int (x_ray_context ["parent_id" ], 16 ),
310310 sampling_priority = float (x_ray_context ["sampled" ]),
311311 ),
312- None ,
312+ data_streams_ctx . get ,
313313 )
314314 return extract_context_from_lambda_context (lambda_context ), data_streams_ctx .get
315315 except Exception as e :
316316 logger .debug ("The trace extractor returned with error %s" , e )
317- return extract_context_from_lambda_context (lambda_context ), None
317+ return extract_context_from_lambda_context (lambda_context ), data_streams_ctx . get
318318
319319
320320def _extract_context_from_eventbridge_sqs_event (event ):
You can’t perform that action at this time.
0 commit comments