Skip to content

Commit

Permalink
more iterations
Browse files Browse the repository at this point in the history
Signed-off-by: Slach <[email protected]>
  • Loading branch information
Slach committed Nov 4, 2024
1 parent 0668194 commit 587cf1e
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions test/integration/integration_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -3052,17 +3052,17 @@ func dropDatabasesFromTestDataDataSet(t *testing.T, r *require.Assertions, ch *T

func (env *TestEnvironment) connectWithWait(r *require.Assertions, sleepBefore, pollInterval, timeOut time.Duration) {
time.Sleep(sleepBefore)
for i := 1; i < 16; i++ {
maxTry := 100
for i := 1; i <= maxTry; i++ {
err := env.connect(timeOut.String())
if i == 15 {
if i == maxTry {
r.NoError(utils.ExecCmd(context.Background(), 180*time.Second, "docker", append(env.GetDefaultComposeCommand(), "ps", "clickhouse")...))
out, dockerErr := env.DockerExecOut("clickhouse", "clickhouse", "client", "--echo", "-q", "'SELECT version()'")
log.Info().Msg(out)
r.NoError(dockerErr)
r.NoError(err)
}
if err != nil {
r.NoError(utils.ExecCmd(context.Background(), 180*time.Second, "docker", "ps", "-a"))
if out, dockerErr := env.DockerExecOut("clickhouse", "clickhouse", "client", "--echo", "-q", "SELECT version()"); dockerErr == nil {
log.Debug().Msg(out)
} else {
Expand Down

0 comments on commit 587cf1e

Please sign in to comment.