diff options
| author | qyryq <qyryq@ydb.tech> | 2024-12-20 12:47:54 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-12-20 12:47:54 +0300 |
| commit | 8aa09c7a9463d66b0f3c67cc6c016918dde40f4f (patch) | |
| tree | c182701ebd6af2f18ca314e0bec01e6091e6ca4c | |
| parent | 291222e410d2257cdd34dd27d34503ecce2e00a8 (diff) | |
| download | ydb-8aa09c7a9463d66b0f3c67cc6c016918dde40f4f.tar.gz | |
DataStreams: Fix TestPutRecordsCornerCases (#12816)
| -rw-r--r-- | ydb/services/datastreams/datastreams_ut.cpp | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/ydb/services/datastreams/datastreams_ut.cpp b/ydb/services/datastreams/datastreams_ut.cpp index 3c9c381033..95653817cd 100644 --- a/ydb/services/datastreams/datastreams_ut.cpp +++ b/ydb/services/datastreams/datastreams_ut.cpp @@ -122,13 +122,13 @@ public: UNIT_ASSERT_VALUES_EQUAL(NMsgBusProxy::MSTATUS_OK, alterClient.AlterUserAttributes("/", "Root", {{"folder_id", DEFAULT_FOLDER_ID}, {"cloud_id", DEFAULT_CLOUD_ID}, - {"database_id", "root"}})); + {"database_id", "root"}})); } DataStreamsClient = std::make_unique<NYDS_V1::TDataStreamsClient>(*Driver, TCommonClientSettings() .AuthToken("user@builtin")); - + } public: @@ -1477,6 +1477,9 @@ Y_UNIT_TEST_SUITE(DataStreams) { UNIT_ASSERT_VALUES_EQUAL(result.IsTransportError(), false); UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString()); } + + GrantConnect(*driver, "user2@builtin"); + kikimr->GetRuntime()->SetLogPriority(NKikimrServices::PQ_READ_PROXY, NLog::EPriority::PRI_DEBUG); NYDS_V1::TDataStreamsClient client(*driver, TCommonClientSettings().AuthToken("user2@builtin")); @@ -2055,6 +2058,7 @@ Y_UNIT_TEST_SUITE(DataStreams) { UNIT_ASSERT_VALUES_EQUAL_C(result.GetStatus(), EStatus::SUCCESS, result.GetIssues().ToString()); } + const ui32 recordsCount = 30; std::vector<NYDS_V1::TDataRecord> records; for (ui32 i = 1; i <= recordsCount; ++i) { |