From 94ceda08021aa97da6ae30abca9cb2dbdd420ca2 Mon Sep 17 00:00:00 2001
From: Jerry Zhao <ch3nzhao@gmail.com>
Date: Tue, 20 Oct 2026 02:31:29 +0000
Subject: [PATCH] test: preserve Stream concurrency failure logs

---
 tests/compact_collection_write_e2e_test.cpp | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/tests/compact_collection_write_e2e_test.cpp b/tests/compact_collection_write_e2e_test.cpp
index 9a8b7416c..a8630434f 100644
--- a/tests/compact_collection_write_e2e_test.cpp
+++ b/tests/compact_collection_write_e2e_test.cpp
@@ -963,6 +963,7 @@ TEST_P(GroupedStreamWriteConcurrencyE2e,
   disk.PreserveOnFailure();
   {
     Server server(disk, 1);
+    server.PreserveOnFailure();
     Client client(server.port());
     for (const auto* id : {"1-0", "2-0", "3-0"})
       ASSERT_EQ(client.Command({"XADD", key, id, "f", initial}).text_, id);
@@ -1017,6 +1018,8 @@ TEST_P(GroupedStreamWriteConcurrencyE2e,
     ASSERT_EQ(server.Wait(true), 0) << server.Log();
   }
   Server recovered(disk, 3);
+  // A reply exception unwinds before Wait() can report the recovery log.
+  recovered.PreserveOnFailure();
   Client client(recovered.port());
   check_stream(client);
   EXPECT_EQ(client.Command({"GET", "other-string"}).text_, "progress");