@@ -108,7 +108,7 @@ func drainNode(cc config.ClusterConfig, name string) (*config.Node, error) {
108
108
// ref: https://kubernetes.io/docs/reference/generated/kubectl/kubectl-commands#drain
109
109
kubectl := kapi .KubectlBinaryPath (cc .KubernetesConfig .KubernetesVersion )
110
110
cmd := exec .Command ("sudo" , "KUBECONFIG=/var/lib/minikube/kubeconfig" , kubectl , "drain" , m ,
111
- "--force" , "--grace-period=1" , "--disable-eviction" , "--ignore-daemonsets" , "--delete-emptydir-data" )
111
+ "--force" , "--grace-period=1" , "--skip-wait-for-delete-timeout=1" , "-- disable-eviction" , "--ignore-daemonsets" , "--delete-emptydir-data" , "--delete-local -data" )
112
112
if _ , err := runner .RunCmd (cmd ); err != nil {
113
113
klog .Warningf ("unable to drain node %q: %v" , name , err )
114
114
} else {
@@ -121,10 +121,14 @@ func drainNode(cc config.ClusterConfig, name string) (*config.Node, error) {
121
121
return n , err
122
122
}
123
123
124
- err = client .CoreV1 ().Nodes ().Delete (context .Background (), m , v1.DeleteOptions {})
124
+ // set 'GracePeriodSeconds: 0' option to delete node immediately (ie, w/o waiting)
125
+ var grace * int64
126
+ err = client .CoreV1 ().Nodes ().Delete (context .Background (), m , v1.DeleteOptions {GracePeriodSeconds : grace })
125
127
if err != nil {
128
+ klog .Errorf ("unable to delete node %q: %v" , name , err )
126
129
return n , err
127
130
}
131
+ klog .Infof ("successfully deleted node %q" , name )
128
132
129
133
cc .Nodes = append (cc .Nodes [:index ], cc .Nodes [index + 1 :]... )
130
134
return n , config .SaveProfile (viper .GetString (config .ProfileName ), & cc )
0 commit comments