fix: etcd migration based on prefix (#540)

Signed-off-by: Dario Tranchitella <dario@tranchitella.eu>
clastix · Aug 12, 2024 · 09310b5 · 09310b5
1 parent 1731e8c
commit 09310b5
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/internal/datastore/etcd.go b/internal/datastore/etcd.go
@@ -182,9 +182,7 @@ func (e *EtcdClient) Migrate(ctx context.Context, tcp kamajiv1alpha1.TenantContr
 		return err
 	}
 
-	key := e.buildKey(fmt.Sprintf("%s_%s", tcp.GetNamespace(), tcp.GetName()))
-
-	response, err := e.Client.Get(ctx, key, etcdclient.WithPrefix())
+	response, err := e.Client.Get(ctx, e.buildKey(tcp.Status.Storage.Setup.Schema), etcdclient.WithPrefix())
 	if err != nil {
 		return err
 	}