From 48013845f005a53645d8b3033d8a1922d7362e12 Mon Sep 17 00:00:00 2001 From: Konstantin Knizhnik Date: Thu, 28 Mar 2024 20:58:52 +0200 Subject: [PATCH] Fix test --- .../regress/test_pageserver_restarts_under_workload.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/test_runner/regress/test_pageserver_restarts_under_workload.py b/test_runner/regress/test_pageserver_restarts_under_workload.py index 4225fcbc02..2905e1fd1c 100644 --- a/test_runner/regress/test_pageserver_restarts_under_workload.py +++ b/test_runner/regress/test_pageserver_restarts_under_workload.py @@ -13,7 +13,9 @@ from fixtures.neon_fixtures import NeonEnv, PgBin def test_pageserver_restarts_under_worload(neon_simple_env: NeonEnv, pg_bin: PgBin): env = neon_simple_env env.neon_cli.create_branch("test_pageserver_restarts") - endpoint = env.endpoints.create_start("test_pageserver_restarts", config_lines=["effective_io_concurrency=100"]) + endpoint = env.endpoints.create_start( + "test_pageserver_restarts", config_lines=["effective_io_concurrency=100"] + ) n_restarts = 100 scale = 10 @@ -21,7 +23,7 @@ def test_pageserver_restarts_under_worload(neon_simple_env: NeonEnv, pg_bin: PgB def run_pgbench(connstr: str): log.info(f"Start a pgbench workload on pg {connstr}") pg_bin.run_capture(["pgbench", "-i", f"-s{scale}", connstr]) - pg_bin.run_capture(["pgbench", f"-c 10 -f select.sql -T{n_restarts}", connstr]) + pg_bin.run_capture(["pgbench", "-c", "10", "-f", "select.sql", f"-T{n_restarts}", connstr]) thread = threading.Thread(target=run_pgbench, args=(endpoint.connstr(),), daemon=True) thread.start()