diff --git a/pkg/kube/kwait.go b/pkg/kube/kwait.go index 936445037..e72e4b93d 100644 --- a/pkg/kube/kwait.go +++ b/pkg/kube/kwait.go @@ -52,7 +52,6 @@ func (w *kstatusWaiter) wait(resourceList ResourceList, timeout time.Duration, w defer cancel() cancelCtx, cancel := context.WithCancel(ctx) defer cancel() - // TODO maybe a simpler way to transfer the objects runtimeObjs := []runtime.Object{} for _, resource := range resourceList { switch value := AsVersioned(resource).(type) { diff --git a/pkg/kube/kwait_test.go b/pkg/kube/kwait_test.go index 8504025da..1bc80d8ee 100644 --- a/pkg/kube/kwait_test.go +++ b/pkg/kube/kwait_test.go @@ -18,13 +18,14 @@ package kube // import "helm.sh/helm/v3/pkg/kube" import ( "errors" + "log" "testing" "time" "github.com/stretchr/testify/assert" "github.com/stretchr/testify/require" - batchv1 "k8s.io/api/batch/v1" appsv1 "k8s.io/api/apps/v1" + batchv1 "k8s.io/api/batch/v1" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/api/meta" "k8s.io/apimachinery/pkg/apis/meta/v1/unstructured" @@ -166,7 +167,7 @@ func TestKWaitJob(t *testing.T) { fakeMapper := testutil.NewFakeRESTMapper( v1.SchemeGroupVersion.WithKind("Pod"), appsv1.SchemeGroupVersion.WithKind("Deployment"), - batchv1.SchemeGroupVersion.WithKind("Job"), + batchv1.SchemeGroupVersion.WithKind("Job"), ) objs := []runtime.Object{} statusWatcher := watcher.NewDefaultStatusWatcher(fakeClient, fakeMapper) @@ -181,9 +182,9 @@ func TestKWaitJob(t *testing.T) { assert.NoError(t, err) } kwaiter := kstatusWaiter{ - sw: statusWatcher, - log: c.Log, - pausedAsReady: tt.pausedAsReady, + sw: statusWatcher, + log: log.Printf, + pausedAsReady: tt.pausedAsReady, } resourceList := ResourceList{}