Parsed test spec with 2 sessions starting permutation: s0_setup s0_is_setup s1_setup s1_is_setup s0_add_message s0_store_lsn s1_add_message s1_store_lsn s0_compare s0_reset s1_reset step s0_setup: SELECT pg_replication_origin_session_setup('origin'); pg_replication_origin_session_setup ----------------------------------- (1 row) step s0_is_setup: SELECT pg_replication_origin_session_is_setup(); pg_replication_origin_session_is_setup -------------------------------------- t (1 row) step s1_setup: SELECT pg_replication_origin_session_setup('origin', pid) FROM pg_stat_activity WHERE application_name = 'isolation/parallel_session_origin/s0'; pg_replication_origin_session_setup ----------------------------------- (1 row) step s1_is_setup: SELECT pg_replication_origin_session_is_setup(); pg_replication_origin_session_is_setup -------------------------------------- t (1 row) step s0_add_message: SELECT 1 FROM pg_logical_emit_message(true, 'prefix', 'message on s0'); ?column? -------- 1 (1 row) step s0_store_lsn: INSERT INTO local_lsn_store SELECT 0, local_lsn FROM pg_replication_origin_status; step s1_add_message: SELECT 1 FROM pg_logical_emit_message(true, 'prefix', 'message on s1'); ?column? -------- 1 (1 row) step s1_store_lsn: INSERT INTO local_lsn_store SELECT 1, local_lsn FROM pg_replication_origin_status; step s0_compare: SELECT s0.lsn < s1.lsn FROM local_lsn_store as s0, local_lsn_store as s1 WHERE s0.session = 0 AND s1.session = 1; ?column? -------- t (1 row) step s0_reset: SELECT pg_replication_origin_session_reset(); pg_replication_origin_session_reset ----------------------------------- (1 row) step s1_reset: SELECT pg_replication_origin_session_reset(); pg_replication_origin_session_reset ----------------------------------- (1 row)