Fix error check.

k8ssandra · Dec 11, 2023 · 95975df · 95975df
1 parent e43825d
commit 95975df
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/controllers/medusa/medusarestorejob_controller.go b/controllers/medusa/medusarestorejob_controller.go
@@ -177,7 +177,13 @@ func (r *MedusaRestoreJobReconciler) Reconcile(ctx context.Context, req ctrl.Req
 	}
 
 	request.Log.Info("The restore operation is complete")
-	medusa.RefreshSecrets(request.Datacenter, ctx, r.Client, request.Log, r.DefaultDelay)
+
+	err = medusa.RefreshSecrets(request.Datacenter, ctx, r.Client, request.Log, r.DefaultDelay)
+	if err != nil {
+		request.Log.Error(err, "Failed to refresh Cassandra users in the DB")
+		// Not going to bother applying updates here since we hit an error.
+		return ctrl.Result{RequeueAfter: r.DefaultDelay}, err
+	}
 
 	return ctrl.Result{}, nil
 }