File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change 7070
7171def _dsm_set_context_sqs_or_sns_event (event , event_type ):
7272 for record in event .get ("Records" , [])[1 :]:
73- if arn := get_source_arn_sqs_or_sns (record , event_type ):
73+ if arn := _get_source_arn_sqs_or_sns (record , event_type ):
7474 context = _extract_context_from_sqs_or_sns_record (record )
7575 _dsm_set_checkpoint (context , event_type , arn )
7676
@@ -82,7 +82,7 @@ def _dsm_set_context_kinesis_event(event):
8282 _dsm_set_checkpoint (context , "kinesis" , arn )
8383
8484
85- def get_source_arn_sqs_or_sns (record , event_type ):
85+ def _get_source_arn_sqs_or_sns (record , event_type ):
8686 return (
8787 record .get ("Sns" , {}).get ("TopicArn" )
8888 if event_type == "sns"
@@ -271,7 +271,7 @@ def extract_context_from_sqs_or_sns_event_or_context(
271271
272272 try :
273273 first_record = event .get ("Records" )[0 ]
274- source_arn = get_source_arn_sqs_or_sns (first_record , event_type )
274+ source_arn = _get_source_arn_sqs_or_sns (first_record , event_type )
275275 dd_data = _extract_context_from_sqs_or_sns_record (first_record )
276276 if dd_data :
277277 if is_step_function_event (dd_data ):
You can’t perform that action at this time.
0 commit comments