TEST

Author: s3rj1k

controllers/awscluster_controller_test.go

@@ -1479,8 +1479,8 @@ func mockedDeleteVPCCalls(m *mocks.MockEC2APIMockRecorder) {
 	m.DescribeVpcEndpointsPages(gomock.Eq(&ec2.DescribeVpcEndpointsInput{
 		Filters: []*ec2.Filter{
 			{
-				Name:   aws.String("tag-key"),
-				Values: []*string{aws.String("sigs.k8s.io/cluster-api-provider-aws/cluster/test-cluster")},
+				Name:   aws.String("tag:sigs.k8s.io/cluster-api-provider-aws/cluster/test-cluster"),
+				Values: []*string{aws.String("owned")},
 			},
 			{
 				Name:   aws.String("vpc-id"),

pkg/cloud/services/network/vpc.go

@@ -277,7 +277,7 @@ func (s *Service) deleteVPCEndpoints() error {
 	}
 
 	// Get all existing endpoints.
-	endpoints, err := s.describeVPCEndpoints(filter.EC2.Cluster(s.scope.Name()))
+	endpoints, err := s.describeVPCEndpoints(filter.EC2.ClusterOwned(s.scope.Name()))
 	if err != nil {
 		return errors.Wrap(err, "failed to describe vpc endpoints")
 	}

test/e2e/shared/suite.go

@@ -145,7 +145,7 @@ func Node1BeforeSuite(e2eCtx *E2EContext) []byte {
 				success = false
 			}
 			return success
-		}, 30*time.Minute, 15*time.Second).Should(BeTrue(), "Should've eventually succeeded creating an AWS CloudFormation stack")
+		}, 15*time.Minute, 5*time.Second).Should(BeTrue(), "Should've eventually succeeded creating an AWS CloudFormation stack")
 	}
 
 	ensureStackTags(e2eCtx.AWSSession, bootstrapTemplate.Spec.StackName, bootstrapTags)