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 70
70
71
71
def _dsm_set_context_sqs_or_sns_event (event , event_type ):
72
72
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 ):
74
74
context = _extract_context_from_sqs_or_sns_record (record )
75
75
_dsm_set_checkpoint (context , event_type , arn )
76
76
@@ -82,7 +82,7 @@ def _dsm_set_context_kinesis_event(event):
82
82
_dsm_set_checkpoint (context , "kinesis" , arn )
83
83
84
84
85
- def get_source_arn_sqs_or_sns (record , event_type ):
85
+ def _get_source_arn_sqs_or_sns (record , event_type ):
86
86
return (
87
87
record .get ("Sns" , {}).get ("TopicArn" )
88
88
if event_type == "sns"
@@ -271,7 +271,7 @@ def extract_context_from_sqs_or_sns_event_or_context(
271
271
272
272
try :
273
273
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 )
275
275
dd_data = _extract_context_from_sqs_or_sns_record (first_record )
276
276
if dd_data :
277
277
if is_step_function_event (dd_data ):
You can’t perform that action at this time.
0 commit comments