File tree Expand file tree Collapse file tree 2 files changed +2
-39
lines changed
core/persqueue/ut/ut_with_sdk Expand file tree Collapse file tree 2 files changed +2
-39
lines changed Original file line number Diff line number Diff line change @@ -723,29 +723,7 @@ Y_UNIT_TEST_SUITE(TopicAutoscaling) {
723
723
f.Wait ();
724
724
725
725
auto v = f.GetValueSync ();
726
- UNIT_ASSERT_C (!v.IsSuccess (), " Must receve error becuse max-partition is not 0" );
727
- }
728
-
729
- {
730
- TAlterTopicSettings alterSettings;
731
- alterSettings
732
- .BeginAlterPartitioningSettings ()
733
- .MaxActivePartitions (0 )
734
- .BeginAlterAutoPartitioningSettings ()
735
- .Strategy (EAutoPartitioningStrategy::Disabled)
736
- .EndAlterAutoPartitioningSettings ()
737
- .EndAlterTopicPartitioningSettings ();
738
- auto f = client.AlterTopic (topicName, alterSettings);
739
- f.Wait ();
740
-
741
- auto v = f.GetValueSync ();
742
- UNIT_ASSERT_C (v.IsSuccess (), " Error: " << v);
743
- }
744
-
745
- {
746
- auto describeAfterAlter = client.DescribeTopic (topicName).GetValueSync ();
747
-
748
- UNIT_ASSERT_VALUES_EQUAL (describeAfterAlter.GetTopicDescription ().GetPartitioningSettings ().GetAutoPartitioningSettings ().GetStrategy (), EAutoPartitioningStrategy::Disabled);
726
+ UNIT_ASSERT_C (!v.IsSuccess (), " Must receve error becuse disabling is not supported" );
749
727
}
750
728
}
751
729
Original file line number Diff line number Diff line change @@ -2909,23 +2909,8 @@ Y_UNIT_TEST_SUITE(DataStreams) {
2909
2909
).ExtractValueSync ();
2910
2910
2911
2911
UNIT_ASSERT_VALUES_EQUAL (result.IsTransportError (), false );
2912
- if (result.GetStatus () != EStatus::SUCCESS) {
2913
- result.GetIssues ().PrintTo (Cerr);
2914
- }
2915
- UNIT_ASSERT_VALUES_EQUAL_C (result.GetStatus (), EStatus::SUCCESS, result.GetIssues ().ToString ());
2916
- }
2917
-
2918
- {
2919
- auto result = testServer.DataStreamsClient ->DescribeStream (streamName2).ExtractValueSync ();
2920
- UNIT_ASSERT_VALUES_EQUAL (result.IsTransportError (), false );
2921
- Cerr << result.GetIssues ().ToString () << " \n " ;
2922
- UNIT_ASSERT_VALUES_EQUAL_C (result.GetStatus (), EStatus::SUCCESS, result.GetIssues ().ToString ());
2923
-
2924
- auto & d = result.GetResult ().stream_description ();
2925
- UNIT_ASSERT_VALUES_EQUAL (d.stream_status (), YDS_V1::StreamDescription::ACTIVE);
2926
- UNIT_ASSERT_VALUES_EQUAL (d.partitioning_settings ().auto_partitioning_settings ().strategy (), ::Ydb::DataStreams::V1::AutoPartitioningStrategy::AUTO_PARTITIONING_STRATEGY_DISABLED);
2912
+ UNIT_ASSERT_VALUES_EQUAL_C (result.GetStatus (), EStatus::BAD_REQUEST, result.GetIssues ().ToString ());
2927
2913
}
2928
-
2929
2914
}
2930
2915
2931
2916
}
You can’t perform that action at this time.
0 commit comments