Parsed test spec with 2 sessions starting permutation: s1_sub1 s2_insert1 s1_sub2 s2_insert2 s1_unsub1 s2_update s1_resub1 s2_delete s1_unsub2 step s1_sub1: SELECT pgr.subscribe('csub_q1', 'SELECT * FROM csub'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q1"} (1 row) step s2_insert1: INSERT INTO csub (val) VALUES ('row1'); step s1_sub2: SELECT pgr.subscribe('csub_q2', 'SELECT * FROM csub WHERE val IS NOT NULL'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q2"} (1 row) step s2_insert2: INSERT INTO csub (val) VALUES ('row2'); step s1_unsub1: SELECT pgr.unsubscribe('csub_q1'); unsubscribe ----------- t (1 row) step s2_update: UPDATE csub SET val = 'modified' WHERE val = 'row1'; step s1_resub1: SELECT pgr.subscribe('csub_q1', 'SELECT * FROM csub'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q1"} (1 row) step s2_delete: DELETE FROM csub WHERE val = 'row2'; step s1_unsub2: SELECT pgr.unsubscribe('csub_q2'); unsubscribe ----------- t (1 row) starting permutation: s2_insert1 s1_sub1 s2_insert2 s1_sub2 s2_update s1_unsub1 s2_delete s1_resub1 s1_unsub2 step s2_insert1: INSERT INTO csub (val) VALUES ('row1'); step s1_sub1: SELECT pgr.subscribe('csub_q1', 'SELECT * FROM csub'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q1"} (1 row) step s2_insert2: INSERT INTO csub (val) VALUES ('row2'); step s1_sub2: SELECT pgr.subscribe('csub_q2', 'SELECT * FROM csub WHERE val IS NOT NULL'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q2"} (1 row) step s2_update: UPDATE csub SET val = 'modified' WHERE val = 'row1'; step s1_unsub1: SELECT pgr.unsubscribe('csub_q1'); unsubscribe ----------- t (1 row) step s2_delete: DELETE FROM csub WHERE val = 'row2'; step s1_resub1: SELECT pgr.subscribe('csub_q1', 'SELECT * FROM csub'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q1"} (1 row) step s1_unsub2: SELECT pgr.unsubscribe('csub_q2'); unsubscribe ----------- t (1 row) starting permutation: s1_sub1 s1_unsub1 s2_insert1 s1_resub1 s2_insert2 s1_sub2 s2_update s1_unsub2 s2_delete step s1_sub1: SELECT pgr.subscribe('csub_q1', 'SELECT * FROM csub'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q1"} (1 row) step s1_unsub1: SELECT pgr.unsubscribe('csub_q1'); unsubscribe ----------- t (1 row) step s2_insert1: INSERT INTO csub (val) VALUES ('row1'); step s1_resub1: SELECT pgr.subscribe('csub_q1', 'SELECT * FROM csub'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q1"} (1 row) step s2_insert2: INSERT INTO csub (val) VALUES ('row2'); step s1_sub2: SELECT pgr.subscribe('csub_q2', 'SELECT * FROM csub WHERE val IS NOT NULL'); subscribe ----------------------------------------------------------------------------- {"mode": "delta", "status": "subscribed", "tables": 1, "query_id": "csub_q2"} (1 row) step s2_update: UPDATE csub SET val = 'modified' WHERE val = 'row1'; step s1_unsub2: SELECT pgr.unsubscribe('csub_q2'); unsubscribe ----------- t (1 row) step s2_delete: DELETE FROM csub WHERE val = 'row2';