We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 512da08 commit bf624a9Copy full SHA for bf624a9
tests/integration/server_restart/main.cpp
@@ -7,6 +7,8 @@
7
8
#include <grpcpp/grpcpp.h>
9
10
+#include <util/string/cast.h>
11
+
12
#include <thread>
13
14
using namespace NYdb;
@@ -180,7 +182,7 @@ TEST_F(ServerRestartTest, RestartOnGetSession) {
180
182
std::optional<TStatus> status;
181
183
while (!closed.load()) {
184
status = client.RetryQuerySync([](NYdb::NQuery::TSession session) {
- return session.ExecuteQuery("SELECT 1", NYdb::NQuery::TTxControl::NoTx()).ExtractValueSync();
185
+ return session.ExecuteQuery("SELECT 1", NYdb::NQuery::TTxControl::BeginTx().CommitTx()).ExtractValueSync();
186
});
187
188
ASSERT_LE(client.GetActiveSessionCount(), 1);
0 commit comments