Fix catching error in test_replication_lag

neondatabase · Feb 7, 2024 · 32f4a56 · 32f4a56
1 parent 28475c6
commit 32f4a56
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git 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
@@ -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()