Ignore already-deleted nodes during rolling update

This commit is contained in:
John Gardiner Myers 2020-04-26 21:41:54 -07:00
parent 5738ffab13
commit df7e0b18b6
1 changed files with 9 additions and 0 deletions

View File

@ -322,6 +322,9 @@ func (c *RollingUpdateCluster) patchTaint(ctx context.Context, node *corev1.Node
}
_, err = c.K8sClient.CoreV1().Nodes().Patch(ctx, node.Name, types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{})
if apierrors.IsNotFound(err) {
return nil
}
return err
}
@ -557,10 +560,16 @@ func (c *RollingUpdateCluster) drainNode(u *cloudinstances.CloudInstanceGroupMem
}
if err := drain.RunCordonOrUncordon(helper, u.Node, true); err != nil {
if apierrors.IsNotFound(err) {
return nil
}
return fmt.Errorf("error cordoning node: %v", err)
}
if err := drain.RunNodeDrain(helper, u.Node.Name); err != nil {
if apierrors.IsNotFound(err) {
return nil
}
return fmt.Errorf("error draining node: %v", err)
}