From 1c4a8515496c535350353e20149a3eed6771ae98 Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Fri, 30 May 2025 07:58:29 +0300 Subject: [PATCH] Make ruff happy --- control_plane/src/endpoint.rs | 3 ++- test_runner/regress/test_replica_promotes.py | 8 ++++---- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/control_plane/src/endpoint.rs b/control_plane/src/endpoint.rs index bc56cd4fdb..0da699b770 100644 --- a/control_plane/src/endpoint.rs +++ b/control_plane/src/endpoint.rs @@ -616,7 +616,8 @@ impl Endpoint { /// Map safekeepers ids to the actual connection strings. fn build_safekeepers_connstrs(&self, sk_ids: Vec) -> Result> { - sk_ids.into_iter() + sk_ids + .into_iter() .map(|node_id| { self.env .safekeepers diff --git a/test_runner/regress/test_replica_promotes.py b/test_runner/regress/test_replica_promotes.py index 85db557010..7dfa8da6ab 100644 --- a/test_runner/regress/test_replica_promotes.py +++ b/test_runner/regress/test_replica_promotes.py @@ -5,9 +5,8 @@ This far, only contains a test that we don't break and that the data is persiste """ import psycopg2 - from fixtures.log_helper import log -from fixtures.neon_fixtures import Endpoint, NeonEnv, wait_replica_caughtup, wait_for_last_flush_lsn +from fixtures.neon_fixtures import Endpoint, NeonEnv, wait_for_last_flush_lsn, wait_replica_caughtup from fixtures.pg_version import PgVersion from pytest import raises @@ -80,7 +79,9 @@ def test_replica_promotes(neon_simple_env: NeonEnv, pg_version: PgVersion): new_primary_cur.execute("select count(*) from t") assert new_primary_cur.fetchone() == (100,) - new_primary_cur.execute("INSERT INTO t (payload) SELECT generate_series(101, 200) RETURNING payload") + new_primary_cur.execute( + "INSERT INTO t (payload) SELECT generate_series(101, 200) RETURNING payload" + ) assert new_primary_cur.fetchall() == [(it,) for it in range(101, 201)] new_primary_cur = new_primary_conn.cursor() @@ -98,7 +99,6 @@ def test_replica_promotes(neon_simple_env: NeonEnv, pg_version: PgVersion): ) log.info(f"Secondary: LSN after workload is {new_primary_cur.fetchone()}") - with secondary.connect() as second_viewpoint_conn: new_primary_cur = second_viewpoint_conn.cursor() new_primary_cur.execute("select payload from t")