@@ -256,6 +256,19 @@ func awaitCSV(t *testing.T, c versioned.Interface, namespace, name string, check
256256 return fetched , err
257257}
258258
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+
259272func waitForDeploymentToDelete (t * testing.T , c operatorclient.ClientInterface , name string ) error {
260273 return wait .Poll (pollInterval , pollDuration , func () (bool , error ) {
261274 t .Logf ("waiting for deployment %s to delete" , name )
@@ -2687,6 +2700,10 @@ func TestUpdateCSVModifyDeploymentName(t *testing.T) {
26872700 _ , err = crc .OperatorsV1alpha1 ().ClusterServiceVersions (testNamespace ).Update (fetchedCSV )
26882701 require .NoError (t , err )
26892702
2703+ // Wait for new deployment to exist
2704+ err = waitForDeployment (t , c , strategyNew .DeploymentSpecs [0 ].Name )
2705+ require .NoError (t , err )
2706+
26902707 // Wait for updated CSV to succeed
26912708 _ , err = fetchCSV (t , crc , csv .Name , testNamespace , csvSucceededChecker )
26922709 require .NoError (t , err )
0 commit comments