diff --git a/safekeeper/src/send_wal.rs b/safekeeper/src/send_wal.rs
index 33f5e598bc7b..430c11b048d3 100644
--- a/safekeeper/src/send_wal.rs
+++ b/safekeeper/src/send_wal.rs
@@ -167,6 +167,10 @@ impl WalSenders {
     fn record_standby_reply(self: &Arc<WalSenders>, id: WalSenderId, reply: &StandbyReply) {
         let mut shared = self.mutex.lock();
         let slot = shared.get_slot_mut(id);
+        info!(
+            "Record standby reply: ts={} apply_lsn={}",
+            reply.reply_ts, reply.apply_lsn
+        );
         match &mut slot.feedback {
             ReplicationFeedback::Standby(sf) => sf.reply = *reply,
             ReplicationFeedback::Pageserver(_) => {
diff --git a/test_runner/regress/test_replication_lag.py b/test_runner/regress/test_replication_lag.py
index 4ca7b634352d..d9c85a6db080 100644
--- a/test_runner/regress/test_replication_lag.py
+++ b/test_runner/regress/test_replication_lag.py
@@ -50,9 +50,7 @@ def run_pgbench(connstr: str):
                     )
                 except Exception as error:
                     print(f"Query failed: {error}")
-                    if not str(error).startswith(
-                        "canceling statement due to conflict with recovery"
-                    ):
+                    if "canceling statement due to conflict with recovery" not in str(error):
                         raise
 
         t.join()