rust/neon
1
0
Fork 0
mirror of https://github.com/neondatabase/neon.git synced 2026-05-24 00:20:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Catch recovery conflict oin all queries

Browse Source
This commit is contained in:
Konstantin Knizhnik
2024-01-26 11:34:33 +02:00
parent 50309cfe83
commit 22a0a6ba0c
1 changed files with 9 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
test_runner/regress/test_replication_lag.py
View File

@@ -35,28 +35,25 @@ def test_replication_lag(neon_simple_env: NeonEnv, pg_bin: PgBin):
with env.endpoints.new_replica_start(origin=primary, endpoint_id="secondary") as secondary:
wait_replica_caughtup(primary, secondary)
time.sleep(
1
) # Without this sleep replica sometime failed to find relation: could not open relation with OID 16404
for _ in range(1, n_iterations):
primary_lsn = primary.safe_psql_scalar(
"SELECT pg_current_wal_flush_lsn()::text", log_query=False
)
secondary_lsn = secondary.safe_psql_scalar(
"SELECT pg_last_wal_replay_lsn()", log_query=False
)
try:
primary_lsn = primary.safe_psql_scalar(
"SELECT pg_current_wal_flush_lsn()::text", log_query=False
)
secondary_lsn = secondary.safe_psql_scalar(
"SELECT pg_last_wal_replay_lsn()", log_query=False
)
balance = secondary.safe_psql_scalar(
"select sum(abalance) from pgbench_accounts"
)
log.info(
f"primary_lsn={primary_lsn}, secondary_lsn={secondary_lsn}, balance={balance}"
)
except Exception as error:
print(f"Query failed: {error}")
if not str(error).startswith(
"canceling statement due to conflict with recovery"
):
raise
log.info(
f"primary_lsn={primary_lsn}, secondary_lsn={secondary_lsn}, balance={balance}"
)
t.join()