From cfbd6de4a00dd281203ded778b1bc3ff23267a61 Mon Sep 17 00:00:00 2001 From: Nitin Goyal Date: Mon, 24 Jul 2023 16:50:35 +0530 Subject: [PATCH] test: resolve golangci-list SA1019 deprication warning utilwait.PollImmediate is deprecated Signed-off-by: Nitin Goyal --- pkg/deploymanager/namespace.go | 3 ++- pkg/deploymanager/olm.go | 5 +++-- pkg/deploymanager/storage_system.go | 5 +++-- 3 files changed, 8 insertions(+), 5 deletions(-) diff --git a/pkg/deploymanager/namespace.go b/pkg/deploymanager/namespace.go index 02a8d387f..1ab1681cf 100644 --- a/pkg/deploymanager/namespace.go +++ b/pkg/deploymanager/namespace.go @@ -1,6 +1,7 @@ package deploymanager import ( + "context" "time" corev1 "k8s.io/api/core/v1" @@ -46,7 +47,7 @@ func (d *DeployManager) DeleteNamespaceAndWait(name string) error { timeout := 600 * time.Second interval := 10 * time.Second - err = utilwait.PollImmediate(interval, timeout, func() (done bool, err error) { + err = utilwait.PollUntilContextTimeout(d.Ctx, interval, timeout, true, func(context.Context) (done bool, err error) { existingNamespace := &corev1.Namespace{} err = d.Client.Get(d.Ctx, client.ObjectKeyFromObject(namespace), existingNamespace) diff --git a/pkg/deploymanager/olm.go b/pkg/deploymanager/olm.go index c5b38c394..a6e5115d1 100644 --- a/pkg/deploymanager/olm.go +++ b/pkg/deploymanager/olm.go @@ -1,6 +1,7 @@ package deploymanager import ( + "context" "fmt" "time" @@ -185,7 +186,7 @@ func (d *DeployManager) WaitForCatalogSource(catalogsource *operatorsv1alpha1.Ca lastReason := "" - err := utilwait.PollImmediate(interval, timeout, func() (done bool, err error) { + err := utilwait.PollUntilContextTimeout(d.Ctx, interval, timeout, true, func(context.Context) (done bool, err error) { existingCatalogSource := &operatorsv1alpha1.CatalogSource{} err = d.Client.Get(d.Ctx, client.ObjectKeyFromObject(catalogsource), existingCatalogSource) if err != nil { @@ -220,7 +221,7 @@ func (d *DeployManager) WaitForCsv(csv *operatorsv1alpha1.ClusterServiceVersion) lastReason := "" - err := utilwait.PollImmediate(interval, timeout, func() (done bool, err error) { + err := utilwait.PollUntilContextTimeout(d.Ctx, interval, timeout, true, func(context.Context) (done bool, err error) { existingcsv := &operatorsv1alpha1.ClusterServiceVersion{} err = d.Client.Get(d.Ctx, client.ObjectKeyFromObject(csv), existingcsv) if err != nil { diff --git a/pkg/deploymanager/storage_system.go b/pkg/deploymanager/storage_system.go index 78e718d5d..c22aa2174 100644 --- a/pkg/deploymanager/storage_system.go +++ b/pkg/deploymanager/storage_system.go @@ -1,6 +1,7 @@ package deploymanager import ( + "context" "fmt" "time" @@ -75,7 +76,7 @@ func (d *DeployManager) CheckStorageSystemCondition() error { lastReason := "" - err := utilwait.PollImmediate(interval, timeout, func() (done bool, err error) { + err := utilwait.PollUntilContextTimeout(d.Ctx, interval, timeout, true, func(context.Context) (done bool, err error) { storageSystem := &odfv1alpha1.StorageSystem{} err = d.Client.Get(d.Ctx, types.NamespacedName{ Name: stoargeSystemName, @@ -156,7 +157,7 @@ func (d *DeployManager) DeleteStorageSystemAndWait() error { interval := 10 * time.Second lastReason := "" - err = utilwait.PollImmediate(interval, timeout, func() (done bool, err error) { + err = utilwait.PollUntilContextTimeout(d.Ctx, interval, timeout, true, func(context.Context) (done bool, err error) { existingStorageSystem := &odfv1alpha1.StorageSystem{} err = d.Client.Get(d.Ctx, types.NamespacedName{ Name: stoargeSystemName,