diff --git a/control_plane/src/storage.rs b/control_plane/src/storage.rs index ee7ef1cf60..09a941603d 100644 --- a/control_plane/src/storage.rs +++ b/control_plane/src/storage.rs @@ -107,14 +107,6 @@ impl TestStorageControlPlane { .join(",") } - pub fn get_wal_acceptor_conn_info_quoted(&self) -> String { - self.wal_acceptors - .iter() - .map(|wa| format!("\"{}\"", wa.listen)) - .collect::>() - .join(",") - } - pub fn is_running(&self) -> bool { self.test_done.load(Ordering::Relaxed) } diff --git a/integration_tests/tests/test_wal_acceptor.rs b/integration_tests/tests/test_wal_acceptor.rs index 8338a176d8..44f3b8d5d5 100644 --- a/integration_tests/tests/test_wal_acceptor.rs +++ b/integration_tests/tests/test_wal_acceptor.rs @@ -19,12 +19,12 @@ fn test_embedded_wal_proposer() { const REDUNDANCY: usize = 3; let storage_cplane = TestStorageControlPlane::fault_tolerant(&local_env, REDUNDANCY); let mut compute_cplane = ComputeControlPlane::local(&local_env, &storage_cplane.pageserver); - let wal_acceptors = storage_cplane.get_wal_acceptor_conn_info_quoted(); + let wal_acceptors = storage_cplane.get_wal_acceptor_conn_info(); // start postgres let maintli = storage_cplane.get_branch_timeline("main"); let node = compute_cplane.new_test_master_node(maintli); - node.append_conf("postgresql.conf", &format!("wal_acceptors={}\n", wal_acceptors)); + node.append_conf("postgresql.conf", &format!("wal_acceptors='{}'\n", wal_acceptors)); node.start().unwrap(); // check basic work with table