Skip to content

Commit

Permalink
Added e2e for remote Data node #2
Browse files Browse the repository at this point in the history
  • Loading branch information
qurname2 committed Aug 30, 2024
1 parent 24bdf21 commit a21137a
Showing 1 changed file with 7 additions and 6 deletions.
13 changes: 7 additions & 6 deletions test/e2e/ytsaurus_controller_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -836,16 +836,17 @@ var _ = Describe("Basic test for Ytsaurus controller", func() {

By("Creating ytsaurus client")
ytClient := getYtClient(g, namespace)

By("Create a chunk")
_, err := ytClient.CreateNode(ctx, ypath.Path("//tmp/a"), yt.NodeTable, nil)
Expect(err).Should(Succeed())

Eventually(func(g Gomega) {
writer, err := ytClient.WriteTable(ctx, ypath.Path("//tmp/a"), nil)
g.Expect(err).ShouldNot(HaveOccurred())
g.Expect(writer.Write(testRow{A: "123"})).Should(Succeed())
g.Expect(writer.Commit()).Should(Succeed())
}, reactionTimeout, pollInterval).Should(Succeed())
// Eventually(func(g Gomega) {
// writer, err := ytClient.WriteTable(ctx, ypath.Path("//tmp/a"), nil)
// g.Expect(err).ShouldNot(HaveOccurred())
// g.Expect(writer.Write(testRow{A: "123"})).Should(Succeed())
// g.Expect(writer.Commit()).Should(Succeed())
//}, reactionTimeout, pollInterval).Should(Succeed())

Check failure on line 849 in test/e2e/ytsaurus_controller_test.go

View workflow job for this annotation

GitHub Actions / Run checks

commentFormatting: put a space between `//` and comment text (gocritic)
})
It(
"Rpc proxies should require authentication",
Expand Down

0 comments on commit a21137a

Please sign in to comment.