fix test: don\t wait 240 sec if unlucky

Author: ubyte

ydb/core/persqueue/pqrb/mirror_describer.cpp

@@ -41,10 +41,10 @@ void TMirrorDescriber::HandleChangeConfig(TEvPQ::TEvChangePartitionConfig::TPtr&
         Config,
         ev->Get()->Config.GetPartitionConfig().GetMirrorFrom()
     );
-    LOG_NOTICE_S(ctx, NKikimrServices::PQ_MIRROR_DESCRIBER, LogDescription() << " got new config, equal with previous: " << equalConfigs);
+    LOG_INFO_S(ctx, NKikimrServices::PQ_MIRROR_DESCRIBER, LogDescription() << " got new config, equal with previous: " << equalConfigs);
     if (!equalConfigs) {
         Config = ev->Get()->Config.GetPartitionConfig().GetMirrorFrom();
-        LOG_NOTICE_S(ctx, NKikimrServices::PQ_MIRROR_DESCRIBER, LogDescription() << " changing config");
+        LOG_INFO_S(ctx, NKikimrServices::PQ_MIRROR_DESCRIBER, LogDescription() << " changing config");
         StartInit(ctx);
     }
 }

ydb/core/persqueue/ut/ut_with_sdk/mirrorer_autoscaling_ut.cpp

@@ -321,7 +321,8 @@ namespace NKikimr::NPersQueueTests {
                     Server.CleverServer->GetRuntime()->GetAppData(nodeId).PersQueueMirrorReaderFactory = Fabric.get();
                 }
 
-                Server.EnableLogs({NKikimrServices::PQ_READ_PROXY, NKikimrServices::PQ_MIRRORER, NKikimrServices::PQ_MIRROR_DESCRIBER});
+                Server.EnableLogs({NKikimrServices::PQ_READ_PROXY});
+                Server.EnableLogs({NKikimrServices::PQ_MIRRORER, NKikimrServices::PQ_MIRROR_DESCRIBER}, NActors::NLog::PRI_TRACE);
                 Server.AnnoyingClient->CreateConsumer("user");
             }
 
@@ -1038,6 +1039,21 @@ namespace NKikimr::NPersQueueTests {
                 /*ui64 sourceIdLifetime =*/86400,
                 partitionStrategy);
 
+
+            UNIT_ASSERT_VALUES_EQUAL(CountPartitionsByStatus(srcTopicFullName, server).Active, 2);
+
+            for (TString name : {srcTopicFullName, }) {
+                PrintTopicDescription(name, "2", server);
+            }
+            PrechargeTopic(srcTopic, driver, sourcesCount, 1, 1, {});
+            UNIT_ASSERT_VALUES_EQUAL(CountPartitionsByStatus(srcTopicFullName, server).Active, 2);
+            for (TString name : {srcTopicFullName, }) {
+                PrintTopicDescription(name, "3", server);
+            }
+
+            ui64 txId = 1006;
+            SplitPartition(txId++, srcTopicFullName, 1, "\xC0", *ctx.Runtime());
+
             NKikimrPQ::TMirrorPartitionConfig mirrorFrom;
             mirrorFrom.SetEndpoint("localhost");
             mirrorFrom.SetEndpointPort(ctx.Server.GrpcPort);
@@ -1060,24 +1076,11 @@ namespace NKikimr::NPersQueueTests {
                 /*ui64 sourceIdLifetime =*/86400,
                 partitionStrategy);
 
-            UNIT_ASSERT_VALUES_EQUAL(CountPartitionsByStatus(srcTopicFullName, server).Active, 2);
-            // UNIT_ASSERT_VALUES_EQUAL(CountPartitionsByStatus(dstTopicFullName, server).Active, 2);
-            for (TString name : {srcTopicFullName, dstTopicFullName}) {
-                PrintTopicDescription(name, "2", server);
-            }
-            PrechargeTopic(srcTopic, driver, sourcesCount, 1, 1, {});
-            UNIT_ASSERT_VALUES_EQUAL(CountPartitionsByStatus(srcTopicFullName, server).Active, 2);
-            // UNIT_ASSERT_VALUES_EQUAL(CountPartitionsByStatus(dstTopicFullName, server).Active, 2);
-            for (TString name : {srcTopicFullName, dstTopicFullName}) {
-                PrintTopicDescription(name, "3", server);
-            }
-
-            ui64 txId = 1006;
-            SplitPartition(txId++, srcTopicFullName, 1, "\xC0", *ctx.Runtime());
-            for (TString name : {srcTopicFullName, dstTopicFullName}) {
+            for (TString name : {srcTopicFullName, }) {
                 PrintTopicDescription(name, "4", server);
             }
 
+
             THashMap<ui32, ui32> messagesPerPartition;
             // write to source topic
             constexpr TWriteCount writeBatch[]{