diff options
| author | gvit <gvit@ydb.tech> | 2022-11-05 19:29:57 +0300 |
|---|---|---|
| committer | gvit <gvit@ydb.tech> | 2022-11-05 19:29:57 +0300 |
| commit | b4c42e1b5b8489e6081121eda096d2d93f25c49b (patch) | |
| tree | bb344abfffeb48bdaad3c2a7c9ea984f94982a4f | |
| parent | 7259c66aae8e7b8f83ac73e140a815d6282e1168 (diff) | |
| download | ydb-b4c42e1b5b8489e6081121eda096d2d93f25c49b.tar.gz | |
continue switching datashard tests to public api
| -rw-r--r-- | ydb/core/tx/datashard/datashard_ut_order.cpp | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/ydb/core/tx/datashard/datashard_ut_order.cpp b/ydb/core/tx/datashard/datashard_ut_order.cpp index 7ae83116ade..5185737b8fd 100644 --- a/ydb/core/tx/datashard/datashard_ut_order.cpp +++ b/ydb/core/tx/datashard/datashard_ut_order.cpp @@ -4288,16 +4288,15 @@ Y_UNIT_TEST(TestShardSnapshotReadNoEarlyReply) { waitFor([&]{ return blockedCommits.size() >= 2; }, "at least 2 blocked commits"); // Send an additional read request, it must not be blocked - SendRequest(runtime, sender1, MakeContinueRequest(sessionId1, txId1, Q_(R"( + auto f = SendRequest(runtime, MakeSimpleRequestRPC(Q_(R"( SELECT * FROM `/Root/table-1` UNION ALL SELECT * FROM `/Root/table-2` - )"), "/Root")); + )"), sessionId1, txId1, false), "/Root"); { - auto ev = runtime.GrabEdgeEventRethrow<NKqp::TEvKqp::TEvQueryResponse>(sender1); - auto& response = ev->Get()->Record.GetRef(); - UNIT_ASSERT_VALUES_EQUAL(response.GetYdbStatus(), Ydb::StatusIds::SUCCESS); + auto response = AwaitResponse(runtime, f); + UNIT_ASSERT_VALUES_EQUAL(response.operation().status(), Ydb::StatusIds::SUCCESS); } } |