Skip to content

Commit 1c79952

Browse files
authored
Merge pull request #5363 from darkweaver87/fix/warning
🐛 fix(EmptyRoutesDefaultVPCSecurityGroup): empty rule should not produce a warning event
2 parents a8200bd + 9de84ea commit 1c79952

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

pkg/cloud/services/securitygroup/securitygroups.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -440,7 +440,7 @@ func (s *Service) revokeIngressAndEgressRulesFromVPCDefaultSecurityGroup() error
440440
},
441441
}
442442
err = s.revokeSecurityGroupIngressRules(defaultSecurityGroupID, ingressRules)
443-
if err != nil && !awserrors.IsPermissionNotFoundError(errors.Cause(err)) {
443+
if err != nil {
444444
return errors.Wrapf(err, "failed to revoke ingress rules from vpc default security group %q in VPC %q", defaultSecurityGroupID, s.scope.VPC().ID)
445445
}
446446

@@ -453,7 +453,7 @@ func (s *Service) revokeIngressAndEgressRulesFromVPCDefaultSecurityGroup() error
453453
},
454454
}
455455
err = s.revokeSecurityGroupEgressRules(defaultSecurityGroupID, egressRules)
456-
if err != nil && !awserrors.IsPermissionNotFoundError(errors.Cause(err)) {
456+
if err != nil {
457457
return errors.Wrapf(err, "failed to revoke egress rules from vpc default security group %q in VPC %q", defaultSecurityGroupID, s.scope.VPC().ID)
458458
}
459459

@@ -514,7 +514,7 @@ func (s *Service) revokeSecurityGroupIngressRules(id string, rules infrav1.Ingre
514514
input.IpPermissions = append(input.IpPermissions, ingressRuleToSDKType(s.scope, &rule))
515515
}
516516

517-
if _, err := s.EC2Client.RevokeSecurityGroupIngressWithContext(context.TODO(), input); err != nil {
517+
if _, err := s.EC2Client.RevokeSecurityGroupIngressWithContext(context.TODO(), input); err != nil && !awserrors.IsPermissionNotFoundError(errors.Cause(err)) {
518518
record.Warnf(s.scope.InfraCluster(), "FailedRevokeSecurityGroupIngressRules", "Failed to revoke security group ingress rules %v for SecurityGroup %q: %v", rules, id, err)
519519
return errors.Wrapf(err, "failed to revoke security group %q ingress rules: %v", id, rules)
520520
}
@@ -530,7 +530,7 @@ func (s *Service) revokeSecurityGroupEgressRules(id string, rules infrav1.Ingres
530530
input.IpPermissions = append(input.IpPermissions, ingressRuleToSDKType(s.scope, &rule))
531531
}
532532

533-
if _, err := s.EC2Client.RevokeSecurityGroupEgressWithContext(context.TODO(), input); err != nil {
533+
if _, err := s.EC2Client.RevokeSecurityGroupEgressWithContext(context.TODO(), input); err != nil && !awserrors.IsPermissionNotFoundError(errors.Cause(err)) {
534534
record.Warnf(s.scope.InfraCluster(), "FailedRevokeSecurityGroupEgressRules", "Failed to revoke security group egress rules %v for SecurityGroup %q: %v", rules, id, err)
535535
return errors.Wrapf(err, "failed to revoke security group %q egress rules: %v", id, rules)
536536
}

0 commit comments

Comments
 (0)