test(cht): use retries in distributed ddl

ClickHouse · Jan 30, 2022 · fa1316c · fa1316c
1 parent 84323ad
commit fa1316c
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/cht/cht_test.go b/cht/cht_test.go
@@ -256,13 +256,12 @@ PARTITION BY toYYYYMM(EventDate)
 ORDER BY (CounterID, EventDate, intHash32(UserID))
 SAMPLE BY intHash32(UserID)`,
 		})
-
-		require.NoError(t, client.Do(ctx, ch.Query{
+		do(ctx, t, ch.Query{
 			Result:   (&proto.Results{}).Auto(),
 			OnResult: func(ctx context.Context, block proto.Block) error { return nil },
 			Body: `CREATE TABLE hits_distributed ON CLUSTER 'nexus' AS hits
 ENGINE = Distributed('nexus', default, hits, rand())`,
-		}))
+		})
 		t.Run("Insert", func(t *testing.T) {
 			for i := 0; i < 20; i++ {
 				require.NoError(t, client.Do(ctx, ch.Query{