diff options
author | alexnick <alexnick@yandex-team.ru> | 2022-02-22 15:38:26 +0300 |
---|---|---|
committer | alexnick <alexnick@yandex-team.ru> | 2022-02-22 15:38:26 +0300 |
commit | 3e5c61fb083629f80986c5634f8f7afec5107c2e (patch) | |
tree | 07d338d3dca83598e9f4ed3e78b3e26fe6919ea3 | |
parent | cb69ebfc910722a9ecfc2234d781f79e4a60fb60 (diff) | |
download | ydb-3e5c61fb083629f80986c5634f8f7afec5107c2e.tar.gz |
fix for test KIKIMR-14230
ref:2b34a3efa72b7b4ac6508c06f664e38e3d07e746
-rw-r--r-- | ydb/core/persqueue/key.h | 6 | ||||
-rw-r--r-- | ydb/core/persqueue/pq_ut.h | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/ydb/core/persqueue/key.h b/ydb/core/persqueue/key.h index 098c67cf7d..356c0cf6df 100644 --- a/ydb/core/persqueue/key.h +++ b/ydb/core/persqueue/key.h @@ -20,10 +20,10 @@ public: }; enum EMark : char { - MarkUserDeprecated = 'u', - MarkSourceId = 's', + MarkUser = 'c', MarkProtoSourceId = 'p', - MarkUser = 'c' + MarkSourceId = 's', + MarkUserDeprecated = 'u' }; TKeyPrefix(EType type, const ui32 partition) diff --git a/ydb/core/persqueue/pq_ut.h b/ydb/core/persqueue/pq_ut.h index cbba48c173..f5f961022c 100644 --- a/ydb/core/persqueue/pq_ut.h +++ b/ydb/core/persqueue/pq_ut.h @@ -961,9 +961,9 @@ TVector<TString> CmdSourceIdRead(TTestContext& tc) { NPQ::TKeyPrefix ikeyFrom(NPQ::TKeyPrefix::TypeInfo, 0, NPQ::TKeyPrefix::MarkSourceId); range->SetFrom(ikeyFrom.Data(), ikeyFrom.Size()); range->SetIncludeFrom(true); - NPQ::TKeyPrefix ikeyTo(NPQ::TKeyPrefix::TypeInfo, 1, NPQ::TKeyPrefix::MarkSourceId); + NPQ::TKeyPrefix ikeyTo(NPQ::TKeyPrefix::TypeInfo, 0, NPQ::TKeyPrefix::MarkUserDeprecated); range->SetTo(ikeyTo.Data(), ikeyTo.Size()); - range->SetIncludeTo(true); + range->SetIncludeTo(false); Cout << request.Get()->ToString() << Endl; tc.Runtime->SendToPipe(tc.TabletId, tc.Edge, request.Release(), 0, GetPipeConfigWithRetries()); result = tc.Runtime->GrabEdgeEvent<TEvKeyValue::TEvResponse>(handle); |