@@ -121,9 +121,7 @@ var _ = Describe("ClusterOperator controller", func() {
121
121
}))
122
122
123
123
By ("setting upgradeable=false when there's an error determining compatibility" )
124
-
125
- By ("changing the openshift environment variable to be invalid and restarting the ClusterOperator" )
126
- resetCurrentReleaseTo ("" )
124
+ Expect (resetCurrentReleaseTo ("" )).To (Succeed ())
127
125
Eventually (func () error {
128
126
return k8sClient .Delete (ctx , co )
129
127
}).Should (Succeed ())
@@ -139,8 +137,7 @@ var _ = Describe("ClusterOperator controller", func() {
139
137
LastTransitionTime : fixedNow (),
140
138
}))
141
139
142
- By ("setting an appropriate variable for the cluster version and restarting the ClusterOperator" )
143
- resetCurrentReleaseTo (clusterVersion )
140
+ Expect (resetCurrentReleaseTo (clusterVersion )).To (Succeed ())
144
141
Eventually (func () error {
145
142
return k8sClient .Delete (ctx , co )
146
143
}).Should (Succeed ())
@@ -306,10 +303,10 @@ var _ = Describe("ClusterOperator controller", func() {
306
303
// resetCurrentRelease thread safely updates the currentRelease.version and then sets the openshift release
307
304
// env var to the desired version. WARNING: This function should only be used for testing purposes as it
308
305
// goes around the desired logic of only setting the version of the cluster for this operator once.
309
- func resetCurrentReleaseTo (version string ) {
306
+ func resetCurrentReleaseTo (version string ) error {
310
307
currentRelease .mu .Lock ()
311
308
defer currentRelease .mu .Unlock ()
312
309
313
310
currentRelease .version = nil
314
- os .Setenv (releaseEnvVar , version )
311
+ return os .Setenv (releaseEnvVar , version )
315
312
}
0 commit comments