@@ -429,7 +429,7 @@ def _depend_on_lambda_permissions_using_tag(
429
429
dependency, so CloudFormation will automatically wait once it reaches that function, the same
430
430
as if you were using a DependsOn.
431
431
"""
432
- properties = bucket .get ("Properties" , None )
432
+ properties = bucket .get ("Properties" )
433
433
if properties is None :
434
434
properties = {}
435
435
bucket ["Properties" ] = properties
@@ -576,14 +576,14 @@ def to_cloudformation(self, **kwargs): # type: ignore[no-untyped-def]
576
576
sqs_subscription : Dict [str , Any ] = sam_expect (
577
577
self .SqsSubscription , self .relative_id , "SqsSubscription" , is_sam_event = True
578
578
).to_be_a_map ()
579
- queue_arn = sqs_subscription .get ("QueueArn" , None )
580
- queue_url = sqs_subscription .get ("QueueUrl" , None )
579
+ queue_arn = sqs_subscription .get ("QueueArn" )
580
+ queue_url = sqs_subscription .get ("QueueUrl" )
581
581
if not queue_arn or not queue_url :
582
582
raise InvalidEventException (self .relative_id , "No QueueARN or QueueURL provided." )
583
583
584
- queue_policy_logical_id = sqs_subscription .get ("QueuePolicyLogicalId" , None )
585
- batch_size = sqs_subscription .get ("BatchSize" , None )
586
- enabled = sqs_subscription .get ("Enabled" , None )
584
+ queue_policy_logical_id = sqs_subscription .get ("QueuePolicyLogicalId" )
585
+ batch_size = sqs_subscription .get ("BatchSize" )
586
+ enabled = sqs_subscription .get ("Enabled" )
587
587
588
588
queue_policy = self ._inject_sqs_queue_policy ( # type: ignore[no-untyped-call]
589
589
self .Topic , queue_arn , queue_url , function , queue_policy_logical_id
0 commit comments