make replication-slot tests robust and strict

chenyunliang520 · chenyunliang520 · commit cce88aaae974 · 2025-08-24T19:23:28.000+08:00
diff --git a/tests/test_logical_decoding.py b/tests/test_logical_decoding.py
@@ -59,7 +59,7 @@ def _create_slot(cur):
 
 def _read_changes(cur):
     cur.execute(
-        "SELECT data FROM pg_logical_slot_peek_changes(%s, NULL, %s);",
+        "SELECT data FROM pg_logical_slot_get_changes(%s, NULL, %s);",
         (SLOT_NAME, 4096),
     )
     rows = cur.fetchall()

Original file line number	Diff line number	Diff line change
`@@ -59,7 +59,7 @@ def _create_slot(cur):`
`59`	`59`
`60`	`60`	`def _read_changes(cur):`
`61`	`61`	`cur.execute(`
`62`		`- "SELECT data FROM pg_logical_slot_peek_changes(%s, NULL, %s);",`
	`62`	`+ "SELECT data FROM pg_logical_slot_get_changes(%s, NULL, %s);",`
`63`	`63`	`(SLOT_NAME, 4096),`
`64`	`64`	`)`
`65`	`65`	`rows = cur.fetchall()`