Intermediate changes

commit_hash:f6c369e4b7825439c70c9263ad32680b6161df7c

1 files changed, 9 insertions, 1 deletions

diff --git a/yt/yt/core/rpc/unittests/rpc_ut.cpp b/yt/yt/core/rpc/unittests/rpc_ut.cpp
index 146a3cad28..f367c57db4 100644
--- a/yt/yt/core/rpc/unittests/rpc_ut.cpp
+++ b/yt/yt/core/rpc/unittests/rpc_ut.cpp
@@ -789,6 +789,10 @@ TYPED_TEST(TRpcTest, RequestQueueSizeLimit)
 {
     MaybeInitLatch();
 
+    auto testId = TGuid::Create();
+
+    Cerr << Format("Start of the RequestQueueSizeLimit test (Id: %v)", testId) << '\n';
+
     std::vector<TFuture<void>> futures;
     std::vector<TTestProxy> proxies;
 
@@ -801,7 +805,9 @@ TYPED_TEST(TRpcTest, RequestQueueSizeLimit)
 
     for (int i = 0; i <= 30; ++i) {
         auto req = proxies[i].LatchedCall();
-        futures.push_back(req->Invoke().AsVoid());
+        futures.push_back(req->Invoke().AsVoid().Apply(BIND([i, testId] (const TError& error) {
+            Cerr << NYT::Format("Request %v finished (Id: %v, Error: %v)", i, testId, error) << '\n';
+        })));
     }
 
     Sleep(TDuration::MilliSeconds(400));
@@ -816,6 +822,8 @@ TYPED_TEST(TRpcTest, RequestQueueSizeLimit)
     EXPECT_TRUE(AllSucceeded(std::move(futures)).Get().IsOK());
 
     ResetLatch();
+
+    Cerr << Format("End of the RequestQueueSizeLimit test (Id: %v)", testId) << '\n';
 }
 
 TYPED_TEST(TNotGrpcTest, RequesMemoryPressureException)