Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
7 changes: 4 additions & 3 deletions pkg/framework/framework.go
Original file line number Diff line number Diff line change
Expand Up @@ -42,9 +42,10 @@ const (
)

var (
WaitShort = 1 * time.Minute
WaitMedium = 3 * time.Minute
WaitLong = 15 * time.Minute
WaitShort = 1 * time.Minute
WaitMedium = 3 * time.Minute
WaitLong = 15 * time.Minute
WaitOverLong = 30 * time.Minute
)

// DeleteObjectsByLabels list all objects of a given kind by labels and deletes them.
Expand Down
9 changes: 5 additions & 4 deletions pkg/framework/machinesets.go
Original file line number Diff line number Diff line change
Expand Up @@ -308,15 +308,16 @@ func WaitForMachineSet(c client.Client, name string) {
replicas := pointer.Int32PtrDerefOr(machineSet.Spec.Replicas, 0)

if len(machines) != int(replicas) {
return fmt.Errorf("found %d Machines, but MachineSet has %d replicas",
len(machines), int(replicas))
return fmt.Errorf("%q: found %d Machines, but MachineSet has %d replicas",
name, len(machines), int(replicas))
}

running := FilterRunningMachines(machines)

// This could probably be smarter, but seems fine for now.
if len(running) != len(machines) {
return fmt.Errorf("not all Machines are running")
return fmt.Errorf("%q: not all Machines are running: %d of %d",
name, len(running), len(machines))
}

for _, m := range running {
Expand All @@ -331,7 +332,7 @@ func WaitForMachineSet(c client.Client, name string) {
}

return nil
}, WaitLong, RetryMedium).ShouldNot(HaveOccurred())
}, WaitOverLong, RetryMedium).ShouldNot(HaveOccurred())
}

// WaitForMachineSetDelete polls until the given MachineSet is not found, and
Expand Down