@@ -86,13 +86,33 @@ func TestCompatibility(t *testing.T) {
86
86
87
87
// scale up to make sure that the Operator can still manage the Coherence cluster
88
88
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 ))
91
92
cmd .Stdout = os .Stdout
92
93
cmd .Stderr = os .Stderr
93
94
err = cmd .Run ()
94
95
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 ())
96
116
}
97
117
98
118
func InstallPreviousVersion (g * GomegaWithT , ns , name , version , selector string ) {
@@ -107,7 +127,9 @@ func InstallPreviousVersion(g *GomegaWithT, ns, name, version, selector string)
107
127
err = os .MkdirAll (prevDir , os .ModePerm )
108
128
g .Expect (err ).NotTo (HaveOccurred ())
109
129
110
- cmd := exec .Command ("helm" , "fetch" , "--version" , version ,
130
+ var cmd * exec.Cmd
131
+
132
+ cmd = exec .Command ("helm" , "fetch" , "--version" , version ,
111
133
"--untar" , "--untardir" , prevDir , "coherence/coherence-operator" )
112
134
113
135
cmd .Stdout = os .Stdout
0 commit comments