diff options
| author | ildar-khisam <ikhis@ydb.tech> | 2023-01-30 16:20:49 +0300 |
|---|---|---|
| committer | ildar-khisam <ikhis@ydb.tech> | 2023-01-30 16:20:49 +0300 |
| commit | fa320a05d3da5588e60caec22bf721750876384a (patch) | |
| tree | 31e617f4d79916d2f0648aa0ff2287fe67b7d878 | |
| parent | 83e5387f4dd51e161d8be3bca323a541b2d33dac (diff) | |
| download | ydb-fa320a05d3da5588e60caec22bf721750876384a.tar.gz | |
fix TPQTestSlow::TestOnDiskStoredSourceIds
fix TPQTestSlow::TestOnDiskStoredSourceIds
Связанный PR: https://a.yandex-team.ru/review/2007624/details
| -rw-r--r-- | ydb/core/persqueue/ut/common/pq_ut_common.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/ydb/core/persqueue/ut/common/pq_ut_common.cpp b/ydb/core/persqueue/ut/common/pq_ut_common.cpp index 11fc2b18ef5..9143a6bdd64 100644 --- a/ydb/core/persqueue/ut/common/pq_ut_common.cpp +++ b/ydb/core/persqueue/ut/common/pq_ut_common.cpp @@ -802,7 +802,7 @@ TVector<TString> CmdSourceIdRead(TTestContext& tc) { sourceIds.clear(); auto read = request->Record.AddCmdReadRange(); auto range = read->MutableRange(); - NPQ::TKeyPrefix ikeyFrom(NPQ::TKeyPrefix::TypeInfo, 0, NPQ::TKeyPrefix::MarkSourceId); + NPQ::TKeyPrefix ikeyFrom(NPQ::TKeyPrefix::TypeInfo, 0, NPQ::TKeyPrefix::MarkProtoSourceId); range->SetFrom(ikeyFrom.Data(), ikeyFrom.Size()); range->SetIncludeFrom(true); NPQ::TKeyPrefix ikeyTo(NPQ::TKeyPrefix::TypeInfo, 0, NPQ::TKeyPrefix::MarkUserDeprecated); @@ -812,6 +812,7 @@ TVector<TString> CmdSourceIdRead(TTestContext& tc) { tc.Runtime->SendToPipe(tc.TabletId, tc.Edge, request.Release(), 0, GetPipeConfigWithRetries()); result = tc.Runtime->GrabEdgeEvent<TEvKeyValue::TEvResponse>(handle); UNIT_ASSERT(result); + Cout << result->ToString() << Endl; UNIT_ASSERT(result->Record.HasStatus()); UNIT_ASSERT_EQUAL(result->Record.GetStatus(), NMsgBusProxy::MSTATUS_OK); for (ui64 idx = 0; idx < result->Record.ReadRangeResultSize(); ++idx) { |