Reduce number of iteration in test_physical_replication to reduce test time

test_runner/regress/test_physical_replication.py

@@ -6,7 +6,7 @@ from fixtures.neon_fixtures import NeonEnv
 
 def test_physical_replication(neon_simple_env: NeonEnv):
     env = neon_simple_env
-    n_records = 100000
+    n_records = 10000
     with env.endpoints.create_start(
         branch_name="main",
         endpoint_id="primary",
@@ -18,12 +18,15 @@ def test_physical_replication(neon_simple_env: NeonEnv):
                 )
         time.sleep(1)
         with env.endpoints.new_replica_start(origin=primary, endpoint_id="secondary") as secondary:
-            with primary.connect() as p_con:
+            p_con = primary.connect()
-                with p_con.cursor() as p_cur:
+            s_con = secondary.connect()
-                    with secondary.connect() as s_con:
+            count = 0
-                        with s_con.cursor() as s_cur:
+            with p_con.cursor() as p_cur:
-                            for pk in range(n_records):
+                with s_con.cursor() as s_cur:
-                                p_cur.execute("insert into t (pk) values (%s)", (pk,))
+                    for pk in range(n_records):
-                                s_cur.execute(
+                        p_cur.execute("insert into t (pk) values (%s)", (pk,))
-                                    "select * from t where pk=%s", (random.randrange(1, n_records),)
+                        s_cur.execute(
-                                )
+                            "select count(*) from t where pk=%s", (random.randrange(1, n_records),)
+                        )
+                        count += s_cur.fetchall()[0][0]
+            assert count > 0