fix: failed to delete node by apply (#4936)

* fix: failed to delete node by apply Signed-off-by: yangxg <[email protected]> * file format: gofmt -s -w pkg/apply/applydrivers/apply_drivers_default.go Signed-off-by: yangxg <[email protected]> --------- Signed-off-by: yangxg <[email protected]>
labring · Sep 20, 2024 · 76990af · 76990af
1 parent ff82fc3
commit 76990af
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/pkg/apply/applydrivers/apply_drivers_default.go b/pkg/apply/applydrivers/apply_drivers_default.go
@@ -228,7 +228,10 @@ func (c *Applier) scaleCluster(mj, md, nj, nd []string) error {
 	logger.Info("start to scale this cluster")
 	logger.Debug("current cluster: master %s, worker %s", c.ClusterCurrent.GetMasterIPAndPortList(), c.ClusterCurrent.GetNodeIPAndPortList())
 	logger.Debug("desired cluster: master %s, worker %s", c.ClusterDesired.GetMasterIPAndPortList(), c.ClusterDesired.GetNodeIPAndPortList())
-	scaleProcessor, err := processor.NewScaleProcessor(c.ClusterFile, c.ClusterDesired.Name, c.ClusterDesired.Spec.Image, mj, md, nj, nd)
+
+	localpath := constants.Clusterfile(c.ClusterDesired.Name)
+	cf := clusterfile.NewClusterFile(localpath)
+	scaleProcessor, err := processor.NewScaleProcessor(cf, c.ClusterDesired.Name, c.ClusterDesired.Spec.Image, mj, md, nj, nd)
 	if err != nil {
 		return err
 	}