@@ -13,6 +13,7 @@ import (
1313 kerrors "k8s.io/apimachinery/pkg/api/errors"
1414 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
1515 "k8s.io/apimachinery/pkg/util/wait"
16+ "k8s.io/client-go/kubernetes"
1617 "k8s.io/client-go/kubernetes/scheme"
1718 "k8s.io/client-go/rest"
1819
@@ -37,6 +38,7 @@ var _ = g.Describe(`[Jira:"Cluster Version Operator"] cluster-version-operator`,
3738
3839 var (
3940 c * rest.Config
41+ kubeClient kubernetes.Interface
4042 configClient * configv1client.ConfigV1Client
4143 apiExtensionsClient apiextensionsclientset.Interface
4244 rtClient ctrlruntimeclient.Client
@@ -54,6 +56,8 @@ var _ = g.Describe(`[Jira:"Cluster Version Operator"] cluster-version-operator`,
5456 o .Expect (util .SkipIfHypershift (ctx , c )).To (o .BeNil ())
5557 o .Expect (util .SkipIfMicroshift (ctx , c )).To (o .BeNil ())
5658
59+ kubeClient , err = util .GetKubeClient (c )
60+ o .Expect (err ).To (o .BeNil ())
5761 configClient , err = configv1client .NewForConfig (c )
5862 o .Expect (err ).To (o .BeNil ())
5963
@@ -108,6 +112,10 @@ var _ = g.Describe(`[Jira:"Cluster Version Operator"] cluster-version-operator`,
108112 o .Expect (err ).NotTo (o .HaveOccurred ())
109113 needRecover = true
110114
115+ g .By ("Checking if the namespace exists" )
116+ _ , err = kubeClient .CoreV1 ().Namespaces ().Get (ctx , proposal .DefaultConfig ().Namespace , metav1.GetOptions {})
117+ o .Expect (err ).NotTo (o .HaveOccurred ())
118+
111119 g .By ("Checking if the proposal are created" )
112120 o .Expect (wait .PollUntilContextTimeout (ctx , 30 * time .Second , 5 * time .Minute , true , func (ctx context.Context ) (done bool , err error ) {
113121 proposals := proposalv1alpha1.ProposalList {}
0 commit comments