fix

Signed-off-by: Aleksandr Zimin <alexandr.zimin@flant.com>
deckhouse · Feb 26, 2025 · 36b631c · 36b631c
1 parent 625b126
commit 36b631c
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/hooks/go/050-migrate-auth-to-connection/migrate-auth-to-connection.go b/hooks/go/050-migrate-auth-to-connection/migrate-auth-to-connection.go
@@ -334,6 +334,14 @@ func processCephClusterConnection(
 ) (bool, error) {
 	needUpdate := false
 	needNewCephClusterConnection := false
+
+	fmt.Printf("[csi-ceph-migration-from-ceph-cluster-authentication]: Getting CephClusterConnection %s\n", cephClusterConnection.Name)
+	err := cl.Get(ctx, types.NamespacedName{Name: cephClusterConnection.Name, Namespace: ""}, cephClusterConnection)
+	if err != nil {
+		fmt.Printf("[csi-ceph-migration-from-ceph-cluster-authentication]: CephClusterConnection %s get error %s\n", cephClusterConnection.Name, err)
+		return false, err
+	}
+
 	if cephClusterConnection.Spec.UserID != "" && cephClusterConnection.Spec.UserID != cephClusterAuthentication.Spec.UserID {
 		fmt.Printf("[csi-ceph-migration-from-ceph-cluster-authentication]: CephClusterConnection %s UserID %s doesn't match CephClusterAuthentication %s UserID %s and both in use by CephStorageClass %s\n", cephClusterConnection.Name, cephClusterConnection.Spec.UserID, cephClusterAuthentication.Name, cephClusterAuthentication.Spec.UserID, cephStorageClass.Name)
 		needNewCephClusterConnection = true