Skip to content

Commit 6bd11ec

Browse files
committed
Fix CRS test flake
Signed-off-by: Stefan Büringer [email protected]
1 parent 085480a commit 6bd11ec

File tree

1 file changed

+8
-24
lines changed

1 file changed

+8
-24
lines changed

exp/addons/internal/controllers/clusterresourceset_controller_test.go

Lines changed: 8 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ metadata:
120120
teardown := func(t *testing.T, g *WithT, ns *corev1.Namespace) {
121121
t.Helper()
122122

123-
t.Log("Deleting the Kubeconfigsecret")
123+
t.Log("Deleting the Kubeconfig Secret")
124124
secret := &corev1.Secret{
125125
ObjectMeta: metav1.ObjectMeta{
126126
Name: clusterName + "-kubeconfig",
@@ -129,26 +129,16 @@ metadata:
129129
}
130130
g.Expect(env.Delete(ctx, secret)).To(Succeed())
131131

132+
t.Log("Deleting the ClusterResourceSet")
132133
clusterResourceSetInstance := &addonsv1.ClusterResourceSet{
133134
ObjectMeta: metav1.ObjectMeta{
134135
Name: clusterResourceSetName,
135136
Namespace: ns.Name,
136137
},
137138
}
138-
139-
err := env.Get(ctx, client.ObjectKey{Namespace: clusterResourceSetInstance.Namespace, Name: clusterResourceSetInstance.Name}, clusterResourceSetInstance)
140-
if err == nil {
141-
g.Expect(env.Delete(ctx, clusterResourceSetInstance)).To(Succeed())
142-
}
143-
139+
g.Expect(client.IgnoreNotFound(env.Delete(ctx, clusterResourceSetInstance))).To(Succeed())
144140
g.Eventually(func() bool {
145-
crsKey := client.ObjectKey{
146-
Namespace: clusterResourceSetInstance.Namespace,
147-
Name: clusterResourceSetInstance.Name,
148-
}
149-
crs := &addonsv1.ClusterResourceSet{}
150-
err := env.Get(ctx, crsKey, crs)
151-
return err != nil
141+
return apierrors.IsNotFound(env.Get(ctx, client.ObjectKeyFromObject(clusterResourceSetInstance), &addonsv1.ClusterResourceSet{}))
152142
}, timeout).Should(BeTrue())
153143

154144
g.Expect(env.Delete(ctx, &corev1.ConfigMap{ObjectMeta: metav1.ObjectMeta{
@@ -166,25 +156,19 @@ metadata:
166156
Namespace: resourceConfigMapsNamespace,
167157
},
168158
}
169-
if err = env.Get(ctx, client.ObjectKeyFromObject(cm1), cm1); err == nil {
170-
g.Expect(env.Delete(ctx, cm1)).To(Succeed())
171-
}
159+
g.Expect(client.IgnoreNotFound(env.Delete(ctx, cm1))).To(Succeed())
160+
172161
cm2 := &corev1.ConfigMap{
173162
ObjectMeta: metav1.ObjectMeta{
174163
Name: resourceConfigMap2Name,
175164
Namespace: resourceConfigMapsNamespace,
176165
},
177166
}
178-
if err = env.Get(ctx, client.ObjectKeyFromObject(cm2), cm2); err == nil {
179-
g.Expect(env.Delete(ctx, cm2)).To(Succeed())
180-
}
167+
g.Expect(client.IgnoreNotFound(env.Delete(ctx, cm2))).To(Succeed())
181168

182169
g.Expect(env.Delete(ctx, ns)).To(Succeed())
183170

184-
clusterKey := client.ObjectKey{Namespace: testCluster.Namespace, Name: testCluster.Name}
185-
if err = env.Get(ctx, clusterKey, testCluster); err == nil {
186-
g.Expect(env.Delete(ctx, testCluster)).To(Succeed())
187-
}
171+
g.Expect(client.IgnoreNotFound(env.Delete(ctx, testCluster))).To(Succeed())
188172
}
189173

190174
t.Run("Should reconcile a ClusterResourceSet with multiple resources when a cluster with matching label exists", func(t *testing.T) {

0 commit comments

Comments
 (0)