From 50309cfe834c260bb4378e6f1e28463d9a3be047 Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Fri, 26 Jan 2024 10:43:33 +0200 Subject: [PATCH] Fix wait_replica_caughtup function --- test_runner/fixtures/neon_fixtures.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/test_runner/fixtures/neon_fixtures.py b/test_runner/fixtures/neon_fixtures.py index 4361bb0eb7..674246d880 100644 --- a/test_runner/fixtures/neon_fixtures.py +++ b/test_runner/fixtures/neon_fixtures.py @@ -4089,12 +4089,12 @@ def tenant_get_shards( def wait_replica_caughtup(primary: Endpoint, secondary: Endpoint): - primary_lsn = primary.safe_psql_scalar( - "SELECT pg_current_wal_flush_lsn()::text", log_query=False + primary_lsn = Lsn( + primary.safe_psql_scalar("SELECT pg_current_wal_flush_lsn()", log_query=False) ) while True: - secondary_lsn = secondary.safe_psql_scalar( - "SELECT pg_last_wal_replay_lsn()", log_query=False + secondary_lsn = Lsn( + secondary.safe_psql_scalar("SELECT pg_last_wal_replay_lsn()", log_query=False) ) caught_up = secondary_lsn >= primary_lsn log.info(f"caughtup={caught_up}, primary_lsn={primary_lsn}, secondary_lsn={secondary_lsn}")