Skip to content

Commit

Permalink
Add skip wait for delete timeout
Browse files Browse the repository at this point in the history
  • Loading branch information
Alexander Demichev committed Jan 29, 2020
1 parent f0c52c1 commit dc06c7d
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions pkg/controller/machine/controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,8 @@ const (

// Machine has a deletion timestamp
phaseDeleting = "Deleting"

skipWaitForDeleteTimeoutSeconds = 60 * 5
)

var DefaultActuator Actuator
Expand Down Expand Up @@ -339,9 +341,10 @@ func (r *ReconcileMachine) drainNode(machine *machinev1.Machine) error {
klog.Info(fmt.Sprintf("%s pod from Node", verbStr),
"pod", fmt.Sprintf("%s/%s", pod.Name, pod.Namespace))
},
Out: writer{klog.Info},
ErrOut: writer{klog.Error},
DryRun: false,
Out: writer{klog.Info},
ErrOut: writer{klog.Error},
DryRun: false,
SkipWaitForDeleteTimeoutSeconds: skipWaitForDeleteTimeoutSeconds,
}

if err := drain.RunCordonOrUncordon(drainer, node, true); err != nil {
Expand Down

0 comments on commit dc06c7d

Please sign in to comment.