Skip to content

Commit 9dea235

Browse files
committed
fixup! fixup! Use SSA instead of Update for finalizer operations
Signed-off-by: Todd Short <[email protected]>
1 parent dcb26e9 commit 9dea235

File tree

4 files changed

+9
-9
lines changed

4 files changed

+9
-9
lines changed

internal/catalogd/controllers/core/clustercatalog_controller.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -157,7 +157,7 @@ func (r *ClusterCatalogReconciler) reconcile(ctx context.Context, catalog *ocv1.
157157

158158
// Remove the fbcDeletionFinalizer as we do not want a finalizer attached to the catalog
159159
// when it is disabled. Because the finalizer serves no purpose now.
160-
if _, err := finalizerutil.UpdateFinalizers(ctx, clusterCatalogFinalizerOwner, r.Client, catalog); err != nil {
160+
if _, err := finalizerutil.EnsureFinalizers(ctx, clusterCatalogFinalizerOwner, r.Client, catalog); err != nil {
161161
return ctrl.Result{}, fmt.Errorf("error removing finalizer: %v", err)
162162
}
163163

@@ -173,7 +173,7 @@ func (r *ClusterCatalogReconciler) reconcile(ctx context.Context, catalog *ocv1.
173173
if err := r.deleteCatalogCache(ctx, catalog); err != nil {
174174
return ctrl.Result{}, fmt.Errorf("finalizer %q failed: %w", fbcDeletionFinalizer, err)
175175
}
176-
if _, err := finalizerutil.UpdateFinalizers(ctx, clusterCatalogFinalizerOwner, r.Client, catalog); err != nil {
176+
if _, err := finalizerutil.EnsureFinalizers(ctx, clusterCatalogFinalizerOwner, r.Client, catalog); err != nil {
177177
return ctrl.Result{}, fmt.Errorf("error removing finalizer: %v", err)
178178
}
179179
// Update status to reflect that catalog is no longer serving
@@ -182,7 +182,7 @@ func (r *ClusterCatalogReconciler) reconcile(ctx context.Context, catalog *ocv1.
182182
}
183183

184184
// Add finalizer
185-
finalizerAdded, err := finalizerutil.UpdateFinalizers(ctx, clusterCatalogFinalizerOwner, r.Client, catalog, fbcDeletionFinalizer)
185+
finalizerAdded, err := finalizerutil.EnsureFinalizers(ctx, clusterCatalogFinalizerOwner, r.Client, catalog, fbcDeletionFinalizer)
186186
if err != nil {
187187
return ctrl.Result{}, fmt.Errorf("error ensuring finalizer: %v", err)
188188
}

internal/operator-controller/controllers/clusterextension_controller.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -191,7 +191,7 @@ func (r *ClusterExtensionReconciler) handleDeletion(ctx context.Context, ext *oc
191191
}
192192
// Remove all finalizers in a single patch operation
193193
if removeFinalizers {
194-
if _, err := finalizerutil.UpdateFinalizers(ctx, clusterExtensionFinalizerOwner, r.Client, ext); err != nil {
194+
if _, err := finalizerutil.EnsureFinalizers(ctx, clusterExtensionFinalizerOwner, r.Client, ext); err != nil {
195195
setStatusProgressing(ext, err)
196196
return ctrl.Result{}, fmt.Errorf("error removing finalizers: %v", err)
197197
}
@@ -217,7 +217,7 @@ func (r *ClusterExtensionReconciler) reconcile(ctx context.Context, ext *ocv1.Cl
217217
finalizers = append(finalizers, finalizerKey)
218218
}
219219
if len(finalizers) > 0 {
220-
if _, err := finalizerutil.UpdateFinalizers(ctx, clusterExtensionFinalizerOwner, r.Client, ext, finalizers...); err != nil {
220+
if _, err := finalizerutil.EnsureFinalizers(ctx, clusterExtensionFinalizerOwner, r.Client, ext, finalizers...); err != nil {
221221
setStatusProgressing(ext, err)
222222
return ctrl.Result{}, fmt.Errorf("error ensuring finalizers: %v", err)
223223
}

internal/operator-controller/controllers/clusterextensionrevision_controller.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -124,7 +124,7 @@ func (c *ClusterExtensionRevisionReconciler) reconcile(ctx context.Context, rev
124124
//
125125
// Reconcile
126126
//
127-
if _, err := finalizerutil.UpdateFinalizers(ctx, cluserExtensionRevisionFinalizerOwner, c.Client, rev, clusterExtensionRevisionTeardownFinalizer); err != nil {
127+
if _, err := finalizerutil.EnsureFinalizers(ctx, cluserExtensionRevisionFinalizerOwner, c.Client, rev, clusterExtensionRevisionTeardownFinalizer); err != nil {
128128
meta.SetStatusCondition(&rev.Status.Conditions, metav1.Condition{
129129
Type: ocv1.ClusterExtensionRevisionTypeAvailable,
130130
Status: metav1.ConditionFalse,
@@ -353,7 +353,7 @@ func (c *ClusterExtensionRevisionReconciler) teardown(ctx context.Context, rev *
353353
return ctrl.Result{}, nil
354354
}
355355

356-
if _, err := finalizerutil.UpdateFinalizers(ctx, cluserExtensionRevisionFinalizerOwner, c.Client, rev); err != nil {
356+
if _, err := finalizerutil.EnsureFinalizers(ctx, cluserExtensionRevisionFinalizerOwner, c.Client, rev); err != nil {
357357
return ctrl.Result{}, fmt.Errorf("error removing teardown finalizer: %v", err)
358358
}
359359
return ctrl.Result{}, nil

internal/shared/util/finalizer/finalizer.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,12 +32,12 @@ const (
3232
FinalizerPrefix = "olm.operatorframework.io/"
3333
)
3434

35-
// UpdateFinalizers sets the finalizers on an object to exactly the provided list using server-side apply.
35+
// EnsureFinalizers sets the finalizers on an object to exactly the provided list using server-side apply.
3636
// If no finalizers are supplied, all finalizers will be removed from the object.
3737
// If one finalizer is supplied, all other finalizers will be removed and only the supplied one will remain.
3838
// Returns (true, nil) if the finalizers were changed, (false, nil) if they were already set to the desired value.
3939
// Note: This function will update the passed object with the server response.
40-
func UpdateFinalizers(ctx context.Context, owner string, c client.Client, obj client.Object, finalizers ...string) (bool, error) {
40+
func EnsureFinalizers(ctx context.Context, owner string, c client.Client, obj client.Object, finalizers ...string) (bool, error) {
4141
// Sort the desired finalizers for consistent ordering
4242
newFinalizers := slices.Clone(finalizers)
4343
if newFinalizers == nil {

0 commit comments

Comments
 (0)