Skip to content

Commit f31179a

Browse files
authored
Merge pull request #21572 from pjsharath28/automated-cherry-pick-of-#20840-upstream-release-3.6
Automated cherry pick of #20840
2 parents db8d13a + eff7875 commit f31179a

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"
@@ -847,19 +846,21 @@ func (epc *EtcdProcessCluster) CloseProc(ctx context.Context, finder func(EtcdPr
847846
return fmt.Errorf("failed to find member ID: %w", err)
848847
}
849848

849+
sleepDuration := 500 * time.Millisecond
850+
maxRetries := int((2 * etcdserver.HealthInterval) / sleepDuration)
850851
memberRemoved := false
851-
for i := 0; i < 10; i++ {
852+
for i := 0; i < maxRetries; i++ {
852853
_, err := memberCtl.MemberRemove(ctx, memberID)
853854
if err != nil && strings.Contains(err.Error(), "member not found") {
854855
memberRemoved = true
855856
break
856857
}
857858

858-
time.Sleep(500 * time.Millisecond)
859+
time.Sleep(sleepDuration)
859860
}
860861

861862
if !memberRemoved {
862-
return errors.New("failed to remove member after 10 tries")
863+
return fmt.Errorf("failed to remove member after %d tries", maxRetries)
863864
}
864865

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

0 commit comments

Comments
 (0)