Skip to content

Commit 66c25c3

Browse files
authored
Merge pull request #20840 from linux-on-ibm-z/tests-cluster-member-remove-retries
tests: Change max retries when removing a member from a cluster to reduce flakiness
2 parents 67f8d12 + 789ffa5 commit 66c25c3

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

tests/framework/e2e/cluster.go

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -16,7 +16,6 @@ package e2e
1616

1717
import (
1818
"context"
19-
"errors"
2019
"flag"
2120
"fmt"
2221
"maps"
@@ -834,19 +833,21 @@ func (epc *EtcdProcessCluster) CloseProc(ctx context.Context, finder func(EtcdPr
834833
return fmt.Errorf("failed to find member ID: %w", err)
835834
}
836835

836+
sleepDuration := 500 * time.Millisecond
837+
maxRetries := int((2 * etcdserver.HealthInterval) / sleepDuration)
837838
memberRemoved := false
838-
for i := 0; i < 10; i++ {
839+
for i := 0; i < maxRetries; i++ {
839840
_, err := memberCtl.MemberRemove(ctx, memberID)
840841
if err != nil && strings.Contains(err.Error(), "member not found") {
841842
memberRemoved = true
842843
break
843844
}
844845

845-
time.Sleep(500 * time.Millisecond)
846+
time.Sleep(sleepDuration)
846847
}
847848

848849
if !memberRemoved {
849-
return errors.New("failed to remove member after 10 tries")
850+
return fmt.Errorf("failed to remove member after %d tries", maxRetries)
850851
}
851852

852853
epc.lg.Info("successfully removed member", zap.String("acurl", proc.Config().ClientURL))

0 commit comments

Comments
 (0)