@@ -2,6 +2,7 @@ package tls
2
2
3
3
import (
4
4
"context"
5
+ "fmt"
5
6
"regexp"
6
7
"time"
7
8
@@ -118,7 +119,12 @@ func (c *certManagerController) DeleteDeprecatedIssuerIfExists(ctx context.Conte
118
119
119
120
func (c * certManagerController ) createOrUpdate (ctx context.Context , cr * api.PerconaServerMongoDB , obj client.Object ) (util.ApplyStatus , error ) {
120
121
if err := controllerutil .SetControllerReference (cr , obj , c .scheme ); err != nil {
121
- return "" , errors .Wrap (err , "set controller reference" )
122
+ switch errors .Cause (err ).(type ) {
123
+ case * controllerutil.AlreadyOwnedError :
124
+ fmt .Sprintf ("%s" , err )
125
+ default :
126
+ return "" , errors .Wrap (err , "set controller reference" )
127
+ }
122
128
}
123
129
124
130
status , err := util .Apply (ctx , c .cl , obj )
@@ -314,7 +320,12 @@ func (c *certManagerController) WaitForCerts(ctx context.Context, cr *api.Percon
314
320
continue
315
321
}
316
322
if err = controllerutil .SetControllerReference (cr , secret , c .scheme ); err != nil {
317
- return errors .Wrap (err , "set controller reference" )
323
+ switch errors .Cause (err ).(type ) {
324
+ case * controllerutil.AlreadyOwnedError :
325
+ fmt .Sprintf ("%s" , err )
326
+ default :
327
+ return errors .Wrap (err , "set controller reference" )
328
+ }
318
329
}
319
330
if err = c .cl .Update (ctx , secret ); err != nil {
320
331
return errors .Wrap (err , "failed to update secret" )
0 commit comments