diff options
Diffstat (limited to 'src/test/recovery/t/035_standby_logical_decoding.pl')
| -rw-r--r-- | src/test/recovery/t/035_standby_logical_decoding.pl | 9 |
1 files changed, 6 insertions, 3 deletions
diff --git a/src/test/recovery/t/035_standby_logical_decoding.pl b/src/test/recovery/t/035_standby_logical_decoding.pl index 8d6740c734b..07ff5231d33 100644 --- a/src/test/recovery/t/035_standby_logical_decoding.pl +++ b/src/test/recovery/t/035_standby_logical_decoding.pl @@ -178,13 +178,15 @@ sub check_slots_conflict_reason $res = $node_standby->safe_psql( 'postgres', qq( - select invalidation_reason from pg_replication_slots where slot_name = '$active_slot' and conflicting;)); + select invalidation_reason from pg_replication_slots where slot_name = '$active_slot' and conflicting;) + ); is($res, "$reason", "$active_slot reason for conflict is $reason"); $res = $node_standby->safe_psql( 'postgres', qq( - select invalidation_reason from pg_replication_slots where slot_name = '$inactive_slot' and conflicting;)); + select invalidation_reason from pg_replication_slots where slot_name = '$inactive_slot' and conflicting;) + ); is($res, "$reason", "$inactive_slot reason for conflict is $reason"); } @@ -559,7 +561,8 @@ check_slots_conflict_reason('vacuum_full_', 'rows_removed'); ################################################## # Get the restart_lsn from an invalidated slot -my $restart_lsn = $node_standby->safe_psql('postgres', +my $restart_lsn = $node_standby->safe_psql( + 'postgres', "SELECT restart_lsn FROM pg_replication_slots WHERE slot_name = 'vacuum_full_activeslot' AND conflicting;" ); |