test(statuswait): fix Copilot code review suggestion for goroutine in tests

Signed-off-by: Mohsen Mottaghi <mohsenmottaghi@outlook.com>
(cherry picked from commit d6b35cedeb)
release-4.0
Mohsen Mottaghi 9 months ago committed by Scott Rigby
parent 2a2e6f722a
commit 41a6b364a1
No known key found for this signature in database
GPG Key ID: C7C6FBB5B91C1155

@ -315,11 +315,11 @@ func TestStatusWaitForDelete(t *testing.T) {
for _, objToDelete := range objsToDelete { for _, objToDelete := range objsToDelete {
u := objToDelete.(*unstructured.Unstructured) u := objToDelete.(*unstructured.Unstructured)
gvr := getGVR(t, fakeMapper, u) gvr := getGVR(t, fakeMapper, u)
go func() { go func(gvr schema.GroupVersionResource, u *unstructured.Unstructured) {
time.Sleep(timeUntilPodDelete) time.Sleep(timeUntilPodDelete)
err := fakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName()) err := fakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName())
assert.NoError(t, err) assert.NoError(t, err)
}() }(gvr, u)
} }
resourceList := getResourceListFromRuntimeObjs(t, c, objsToCreate) resourceList := getResourceListFromRuntimeObjs(t, c, objsToCreate)
err := statusWaiter.WaitForDelete(resourceList, timeout) err := statusWaiter.WaitForDelete(resourceList, timeout)
@ -627,11 +627,11 @@ func TestStatusWaitMultipleNamespaces(t *testing.T) {
for _, obj := range objs { for _, obj := range objs {
u := obj.(*unstructured.Unstructured) u := obj.(*unstructured.Unstructured)
gvr := getGVR(t, fakeMapper, u) gvr := getGVR(t, fakeMapper, u)
go func() { go func(gvr schema.GroupVersionResource, u *unstructured.Unstructured) {
time.Sleep(timeUntilDelete) time.Sleep(timeUntilDelete)
err := fakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName()) err := fakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName())
assert.NoError(t, err) assert.NoError(t, err)
}() }(gvr, u)
} }
} }
@ -812,11 +812,11 @@ func TestStatusWaitRestrictedRBAC(t *testing.T) {
for _, obj := range objs { for _, obj := range objs {
u := obj.(*unstructured.Unstructured) u := obj.(*unstructured.Unstructured)
gvr := getGVR(t, fakeMapper, u) gvr := getGVR(t, fakeMapper, u)
go func() { go func(gvr schema.GroupVersionResource, u *unstructured.Unstructured) {
time.Sleep(timeUntilDelete) time.Sleep(timeUntilDelete)
err := baseFakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName()) err := baseFakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName())
assert.NoError(t, err) assert.NoError(t, err)
}() }(gvr, u)
} }
} }
@ -919,11 +919,11 @@ func TestStatusWaitMixedResources(t *testing.T) {
for _, obj := range objs { for _, obj := range objs {
u := obj.(*unstructured.Unstructured) u := obj.(*unstructured.Unstructured)
gvr := getGVR(t, fakeMapper, u) gvr := getGVR(t, fakeMapper, u)
go func() { go func(gvr schema.GroupVersionResource, u *unstructured.Unstructured) {
time.Sleep(timeUntilDelete) time.Sleep(timeUntilDelete)
err := baseFakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName()) err := baseFakeClient.Tracker().Delete(gvr, u.GetNamespace(), u.GetName())
assert.NoError(t, err) assert.NoError(t, err)
}() }(gvr, u)
} }
} }

Loading…
Cancel
Save