fix: no run configure OS in exist node (#3068)

Signed-off-by: redscholar <[email protected]>

Author: redscholar

.gitignore

@@ -35,4 +35,6 @@ _artifacts
 
 # Used during parts of the build process. Files _should_ get cleaned up automatically.
 # This is also a good location for any temporary manfiests used during development
-tmp
+tmp
+_output
+skills

cmd/kk/pkg/bootstrap/os/module.go

@@ -25,6 +25,7 @@ import (
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/core/prepare"
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/core/task"
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/core/util"
+	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/kubernetes"
 )
 
 type ConfigureOSModule struct {
@@ -40,10 +41,13 @@ func (c *ConfigureOSModule) Init() {
 	c.Name = "ConfigureOSModule"
 	c.Desc = "Init os dependencies"
 
+	c.PipelineCache.GetOrSet(common.ClusterStatus, kubernetes.NewKubernetesStatus())
+
 	getOSData := &task.RemoteTask{
 		Name:     "GetOSData",
 		Desc:     "Get OS release",
 		Hosts:    c.Runtime.GetAllHosts(),
+		Prepare:  &kubernetes.NodeInCluster{Not: true},
 		Action:   new(GetOSData),
 		Parallel: true,
 	}
@@ -52,14 +56,16 @@ func (c *ConfigureOSModule) Init() {
 		Name:     "InitOS",
 		Desc:     "Prepare to init OS",
 		Hosts:    c.Runtime.GetAllHosts(),
+		Prepare:  &kubernetes.NodeInCluster{Not: true},
 		Action:   new(NodeConfigureOS),
 		Parallel: true,
 	}
 
 	GenerateScript := &task.RemoteTask{
-		Name:  "GenerateScript",
-		Desc:  "Generate init os script",
-		Hosts: c.Runtime.GetAllHosts(),
+		Name:    "GenerateScript",
+		Desc:    "Generate init os script",
+		Hosts:   c.Runtime.GetAllHosts(),
+		Prepare: &kubernetes.NodeInCluster{Not: true},
 		Action: &action.Template{
 			Template: templates.InitOsScriptTmpl,
 			Dst:      filepath.Join(common.KubeScriptDir, "initOS.sh"),
@@ -75,6 +81,7 @@ func (c *ConfigureOSModule) Init() {
 		Name:     "ExecScript",
 		Desc:     "Exec init os script",
 		Hosts:    c.Runtime.GetAllHosts(),
+		Prepare:  &kubernetes.NodeInCluster{Not: true},
 		Action:   new(NodeExecScript),
 		Parallel: true,
 	}

cmd/kk/pkg/pipelines/add_nodes.go

@@ -52,12 +52,12 @@ func NewAddNodesPipeline(runtime *common.KubeRuntime) error {
 		&artifact.UnArchiveModule{Skip: noArtifact},
 		&os.RepositoryModule{Skip: noArtifact || !runtime.Arg.InstallPackages},
 		&binaries.NodeBinariesModule{},
+		&kubernetes.StatusModule{},
 		&os.ConfigureOSModule{Skip: runtime.Cluster.System.SkipConfigureOS},
 		&registry.RegistryCertsModule{Skip: len(runtime.GetHostsByRole(common.Registry)) == 0},
 		//for one master to multi master kube-vip
 		&loadbalancer.KubevipModule{Skip: !runtime.Cluster.ControlPlaneEndpoint.IsInternalLBEnabledVip()},
 		&kubernetes.RestartKubeletModule{},
-		&kubernetes.StatusModule{},
 		&container.InstallContainerModule{},
 		&container.InstallCriDockerdModule{Skip: runtime.Cluster.Kubernetes.ContainerManager != "docker"},
 		&images.PullModule{Skip: runtime.Arg.SkipPullImages},

cmd/kk/pkg/pipelines/create_cluster.go

@@ -67,8 +67,8 @@ func NewCreateClusterPipeline(runtime *common.KubeRuntime) error {
 			&artifact.UnArchiveModule{Skip: noArtifact},
 			&os.RepositoryModule{Skip: noArtifact || !runtime.Arg.InstallPackages},
 			&binaries.NodeBinariesModule{},
-			&os.ConfigureOSModule{Skip: runtime.Cluster.System.SkipConfigureOS},
 			&kubernetes.StatusModule{},
+			&os.ConfigureOSModule{Skip: runtime.Cluster.System.SkipConfigureOS},
 			&container.InstallContainerModule{},
 			&container.InstallCriDockerdModule{Skip: runtime.Cluster.Kubernetes.ContainerManager != "docker"},
 			&images.CopyImagesToRegistryModule{Skip: skipPushImages},

cmd/kk/pkg/pipelines/init_registry.go

@@ -18,6 +18,7 @@ package pipelines
 
 import (
 	"fmt"
+
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/artifact"
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/binaries"
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/bootstrap/os"
@@ -28,6 +29,7 @@ import (
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/core/module"
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/core/pipeline"
 	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/filesystem"
+	"github.com/kubesphere/kubekey/v3/cmd/kk/pkg/kubernetes"
 	"github.com/pkg/errors"
 )
 
@@ -38,6 +40,7 @@ func NewInitRegistryPipeline(runtime *common.KubeRuntime) error {
 		&precheck.GreetingsModule{},
 		&artifact.UnArchiveModule{Skip: noArtifact},
 		&binaries.RegistryPackageModule{},
+		&kubernetes.StatusModule{},
 		&os.ConfigureOSModule{Skip: runtime.Cluster.System.SkipConfigureOS},
 		&registry.RegistryCertsModule{},
 		&registry.InstallRegistryModule{},