@@ -96,7 +96,7 @@ func (in *CoherenceReconciler) Reconcile(ctx context.Context, request ctrl.Reque
9696 // request for the same resource is already in progress so requeue this one.
9797 if ok := in .Lock (request ); ! ok {
9898 log .Info ("Coherence resource " + request .Namespace + "/" + request .Name + " is already locked, requeue request" )
99- return reconcile.Result {Requeue : true , RequeueAfter : 0 }, nil
99+ return reconcile.Result {RequeueAfter : time . Minute }, nil
100100 }
101101 // Make sure that the request is unlocked when this method exits
102102 defer in .Unlock (request )
@@ -134,7 +134,7 @@ func (in *CoherenceReconciler) Reconcile(ctx context.Context, request ctrl.Reque
134134 msg := fmt .Sprintf ("failed to finalize Coherence resource, %s" , err .Error ())
135135 in .GetEventRecorder ().Event (deployment , coreV1 .EventTypeWarning , reconciler .EventReasonDeleted , msg )
136136 log .Error (err , "Failed to remove finalizer" )
137- return ctrl.Result {Requeue : true }, nil
137+ return ctrl.Result {RequeueAfter : time . Minute }, nil
138138 }
139139 // Remove the finalizer. Once all finalizers have been
140140 // removed, the object will be deleted.
@@ -164,7 +164,7 @@ func (in *CoherenceReconciler) Reconcile(ctx context.Context, request ctrl.Reque
164164 if controllerutil .ContainsFinalizer (deployment , coh .CoherenceFinalizer ) {
165165 err := in .finalizerManager .EnsureFinalizerRemoved (ctx , deployment )
166166 if err != nil && ! apierrors .IsNotFound (err ) {
167- return ctrl.Result {Requeue : true }, errorhandling .NewOperationError ("remove_finalizer" , err ).
167+ return ctrl.Result {}, errorhandling .NewOperationError ("remove_finalizer" , err ).
168168 WithContext ("resource" , deployment .GetName ()).
169169 WithContext ("namespace" , deployment .GetNamespace ()).
170170 WithContext ("reason" , "allow_unsafe_delete" )
@@ -238,7 +238,7 @@ func (in *CoherenceReconciler) Reconcile(ctx context.Context, request ctrl.Reque
238238 }
239239
240240 // create the result
241- result := ctrl.Result {Requeue : false }
241+ result := ctrl.Result {}
242242
243243 hash := deployment .GetGenerationString ()
244244 storeHash , _ := storage .GetHash ()
@@ -253,6 +253,7 @@ func (in *CoherenceReconciler) Reconcile(ctx context.Context, request ctrl.Reque
253253 if err = in .statusManager .UpdateDeploymentStatusHash (ctx , request .NamespacedName , hashNew ); err != nil {
254254 return result , errors .Wrap (err , "error updating deployment status hash" )
255255 }
256+ log .Info ("Updated pre-3.5.0 Coherence resource status hash" , "From" , hash , "To" , hashNew )
256257 return result , nil
257258 }
258259
@@ -369,8 +370,9 @@ func (in *CoherenceReconciler) SetupWithManager(mgr ctrl.Manager, cs clients.Cli
369370 }
370371
371372 in .statusManager = & status.StatusManager {
372- Client : mgr .GetClient (),
373- Log : in .Log .WithName ("status" ),
373+ Client : mgr .GetClient (),
374+ Log : in .Log .WithName ("status" ),
375+ Patcher : in .GetPatcher (),
374376 }
375377
376378 in .resourcesManager = & resources.OperatorSecretManager {
0 commit comments