@@ -256,6 +256,19 @@ func awaitCSV(t *testing.T, c versioned.Interface, namespace, name string, check
256
256
return fetched , err
257
257
}
258
258
259
+ func waitForDeployment (t * testing.T , c operatorclient.ClientInterface , name string ) error {
260
+ return wait .Poll (pollInterval , pollDuration , func () (bool , error ) {
261
+ _ , err := c .GetDeployment (testNamespace , name )
262
+ if err != nil {
263
+ if k8serrors .IsNotFound (err ) {
264
+ return false , nil
265
+ }
266
+ return false , err
267
+ }
268
+ return true , nil
269
+ })
270
+ }
271
+
259
272
func waitForDeploymentToDelete (t * testing.T , c operatorclient.ClientInterface , name string ) error {
260
273
return wait .Poll (pollInterval , pollDuration , func () (bool , error ) {
261
274
t .Logf ("waiting for deployment %s to delete" , name )
@@ -2687,6 +2700,10 @@ func TestUpdateCSVModifyDeploymentName(t *testing.T) {
2687
2700
_ , err = crc .OperatorsV1alpha1 ().ClusterServiceVersions (testNamespace ).Update (fetchedCSV )
2688
2701
require .NoError (t , err )
2689
2702
2703
+ // Wait for new deployment to exist
2704
+ err = waitForDeployment (t , c , strategyNew .DeploymentSpecs [0 ].Name )
2705
+ require .NoError (t , err )
2706
+
2690
2707
// Wait for updated CSV to succeed
2691
2708
_ , err = fetchCSV (t , crc , csv .Name , testNamespace , csvSucceededChecker )
2692
2709
require .NoError (t , err )
0 commit comments