@@ -2,6 +2,7 @@ package tls
22
33import (
44 "context"
5+ "fmt"
56 "regexp"
67 "time"
78
@@ -118,7 +119,12 @@ func (c *certManagerController) DeleteDeprecatedIssuerIfExists(ctx context.Conte
118119
119120func (c * certManagerController ) createOrUpdate (ctx context.Context , cr * api.PerconaServerMongoDB , obj client.Object ) (util.ApplyStatus , error ) {
120121 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+ }
122128 }
123129
124130 status , err := util .Apply (ctx , c .cl , obj )
@@ -314,7 +320,12 @@ func (c *certManagerController) WaitForCerts(ctx context.Context, cr *api.Percon
314320 continue
315321 }
316322 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+ }
318329 }
319330 if err = c .cl .Update (ctx , secret ); err != nil {
320331 return errors .Wrap (err , "failed to update secret" )
0 commit comments