From d499008b4278a0dd78ed787f481674cd19e0f4d6 Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Fri, 19 Jan 2024 22:00:49 +0200 Subject: [PATCH] Set hot_standby_feedback option to ON --- control_plane/src/endpoint.rs | 1 + test_runner/regress/test_replication_lag.py | 2 ++ 2 files changed, 3 insertions(+) diff --git a/control_plane/src/endpoint.rs b/control_plane/src/endpoint.rs index b19a6a1a18..3b033b32fd 100644 --- a/control_plane/src/endpoint.rs +++ b/control_plane/src/endpoint.rs @@ -290,6 +290,7 @@ impl Endpoint { conf.append("wal_log_hints", "off"); conf.append("max_replication_slots", "10"); conf.append("hot_standby", "on"); + conf.append("hot_standby_feedback", "on"); conf.append("shared_buffers", "1MB"); conf.append("fsync", "off"); conf.append("max_connections", "100"); diff --git a/test_runner/regress/test_replication_lag.py b/test_runner/regress/test_replication_lag.py index 2b638eb017..e39c8a1007 100644 --- a/test_runner/regress/test_replication_lag.py +++ b/test_runner/regress/test_replication_lag.py @@ -1,4 +1,5 @@ import threading +import time from fixtures.log_helper import log from fixtures.neon_fixtures import NeonEnv, PgBin @@ -33,6 +34,7 @@ def test_replication_lag(neon_simple_env: NeonEnv, pg_bin: PgBin): t.start() with env.endpoints.new_replica_start(origin=primary, endpoint_id="secondary") as secondary: + time.sleep(10) for _ in range(1, n_iterations): primary_lsn = primary.safe_psql_scalar( "SELECT pg_current_wal_flush_lsn()::text", log_query=False