diff options
| author | mokhotskii <mokhotskii@yandex-team.ru> | 2022-06-10 21:01:59 +0300 |
|---|---|---|
| committer | mokhotskii <mokhotskii@yandex-team.ru> | 2022-06-10 21:01:59 +0300 |
| commit | 84d5626c87e97e75fb24b2fff9249ece342ee1c4 (patch) | |
| tree | 124b2b1ff4e664aad6f9cb634225aa5e7db1f26f | |
| parent | 076a37f0c2f77af6e792b07192555193f2c751a8 (diff) | |
| download | ydb-84d5626c87e97e75fb24b2fff9249ece342ee1c4.tar.gz | |
LOGBROKER-7506 Clean up datastreams-related tests
Clean up datastreams-related tests
ref:2214203e3294a70ca09059e0f97008d749beb734
| -rw-r--r-- | ydb/services/datastreams/datastreams_ut.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/ydb/services/datastreams/datastreams_ut.cpp b/ydb/services/datastreams/datastreams_ut.cpp index 8d5f7cdeac..8f47f8e576 100644 --- a/ydb/services/datastreams/datastreams_ut.cpp +++ b/ydb/services/datastreams/datastreams_ut.cpp @@ -981,7 +981,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { } // check for total number of shards - UNIT_ASSERT_EQUAL(describedShards.size(), 9); + UNIT_ASSERT_VALUES_EQUAL(describedShards.size(), 9); } } @@ -1643,7 +1643,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { NKikimrPQ::TYdsShardIterator protoShardIterator; TString decoded; Base64Decode(result.GetResult().shard_iterator(), decoded); - Y_VERIFY(protoShardIterator.ParseFromString(decoded)); + UNIT_ASSERT(protoShardIterator.ParseFromString(decoded)); UNIT_ASSERT_VALUES_EQUAL(protoShardIterator.GetStreamName(), "/Root/" + streamName); } @@ -1871,7 +1871,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { UNIT_ASSERT_VALUES_EQUAL(result.GetStatus(), EStatus::SUCCESS); } - std::vector<std::string> put_data; + std::vector<std::string> putData; const ui32 recordsCount = 10; { std::string data; @@ -1881,7 +1881,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { std::mt19937 generator{rd()}; for (ui32 i = 1; i <= recordsCount; ++i) { std::shuffle(data.begin(), data.end(), generator); - put_data.push_back(data); + putData.push_back(data); { TString id = Sprintf("%04u", i); NYDS_V1::TDataRecord dataRecord{{data.begin(), data.end()}, id, ""}; @@ -1914,7 +1914,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { UNIT_ASSERT_VALUES_EQUAL( std::stoi(result.GetResult().records().begin()->sequence_number()), i); UNIT_ASSERT_VALUES_EQUAL(MD5::Calc(result.GetResult().records().begin()->data()), - MD5::Calc(put_data[i])); + MD5::Calc(putData[i])); } } } |