# Start a psql session to test the case where the activation process is
# interrupted.
- $psql_create_slot = $primary->background_psql('postgres');
+ $psql_create_slot =
+ $primary->background_psql('postgres', on_error_stop => 0);
# Start the logical decoding activation process upon creating the logical
# slot, but it will wait due to the injection point.
select injection_points_set_local();
select injection_points_attach('logical-decoding-activation', 'wait');
select pg_create_logical_replication_slot('slot_canceled', 'pgoutput');
-\q
));
$primary->wait_for_event('client backend', 'logical-decoding-activation');
$psql_create_slot->quit;
# Test concurrent activation processes run and one is interrupted.
- $psql_create_slot = $primary->background_psql('postgres');
+ $psql_create_slot =
+ $primary->background_psql('postgres', on_error_stop => 0);
# Start a psql session and stops in the middle of the activation
# process.
select injection_points_set_local();
select injection_points_attach('logical-decoding-activation', 'wait');
select pg_create_logical_replication_slot('slot_canceled2', 'pgoutput');
-\q
));
$primary->wait_for_event('client backend', 'logical-decoding-activation');
note("injection_point 'logical-decoding-activation' is reached");