@@ -86,13 +86,33 @@ func TestCompatibility(t *testing.T) {
8686
8787 // scale up to make sure that the Operator can still manage the Coherence cluster
8888 n := fmt .Sprintf ("coherence/%s" , d .Name )
89- t .Logf ("Scaling coherence resource %s in namespace %s to 3 replicas\n " , n , ns )
90- cmd := exec .Command ("kubectl" , "-n" , ns , "scale" , n , "--replicas=3" )
89+ replicas := 3
90+ testContext .Logf ("Scaling coherence resource %s in namespace %s to %d replicas\n " , n , ns , replicas )
91+ cmd := exec .Command ("kubectl" , "-n" , ns , "scale" , n , fmt .Sprintf ("--replicas=%d" , replicas ))
9192 cmd .Stdout = os .Stdout
9293 cmd .Stderr = os .Stderr
9394 err = cmd .Run ()
9495 g .Expect (err ).NotTo (HaveOccurred ())
95- _ = assertDeploymentEventuallyInDesiredState (t , d , 3 )
96+ _ = assertDeploymentEventuallyInDesiredState (t , d , int32 (replicas ))
97+
98+ testContext .Logf ("Updating coherence resource %s in namespace %s\n " , d .Name , ns )
99+ updated := & cohv1.Coherence {}
100+ err = testContext .Client .Get (context .TODO (), d .GetNamespacedName (), updated )
101+ g .Expect (err ).NotTo (HaveOccurred ())
102+
103+ l := updated .Spec .Labels
104+ if l == nil {
105+ l = make (map [string ]string )
106+ }
107+ l ["testCompatibility" ] = "updated"
108+ updated .Spec .Labels = l
109+
110+ err = testContext .Client .Update (testContext .Context , updated )
111+ g .Expect (err ).NotTo (HaveOccurred ())
112+
113+ testContext .Logf ("Waiting for Pods in updated coherence resource %s in namespace %s\n " , d .Name , ns )
114+ _ , err = helper .WaitForPodsWithLabel (testContext , ns , "testCompatibility=updated" , replicas , time .Second * 20 , time .Minute * 10 )
115+ g .Expect (err ).NotTo (HaveOccurred ())
96116}
97117
98118func InstallPreviousVersion (g * GomegaWithT , ns , name , version , selector string ) {
@@ -107,7 +127,9 @@ func InstallPreviousVersion(g *GomegaWithT, ns, name, version, selector string)
107127 err = os .MkdirAll (prevDir , os .ModePerm )
108128 g .Expect (err ).NotTo (HaveOccurred ())
109129
110- cmd := exec .Command ("helm" , "fetch" , "--version" , version ,
130+ var cmd * exec.Cmd
131+
132+ cmd = exec .Command ("helm" , "fetch" , "--version" , version ,
111133 "--untar" , "--untardir" , prevDir , "coherence/coherence-operator" )
112134
113135 cmd .Stdout = os .Stdout
0 commit comments