Parsed test spec with 2 sessions starting permutation: s1set s2set s1pre s2connect s2fill s1write s2changed s2join s2fill s2join step s1set: SET sift.agg_force = on; SET max_parallel_workers_per_gather = 0; step s2set: SET sift.agg_force = on; SET max_parallel_workers_per_gather = 0; step s1pre: UPDATE iso_jc_dim SET id = id + 1000 WHERE id = 300; DELETE FROM iso_jc_dim WHERE id = 299; step s2connect: CREATE INDEX iso_jc_ev_c ON iso_jc_ev USING sift_col (id, dim_id, v) WITH (connect = 'dim_id -> iso_jc_dim(id)'); step s2fill: SELECT sift.col_maintain('iso_jc_ev_c') IS NOT NULL AS maintained; maintained ---------- t (1 row) step s1write: UPDATE iso_jc_dim SET id = id + 2000 WHERE id <= 5; DELETE FROM iso_jc_dim WHERE id IN (50, 51); INSERT INTO iso_jc_dim VALUES (400, 'new'); step s2changed: SELECT count(c.key) AS changed_keys FROM sift._test_col_conn_stamps('iso_jc_ev_c') s, sift._test_conn_changed('iso_jc_dim_c', s.lineage, s.horizon) c; changed_keys ------------ 7 (1 row) step s2join: SELECT iso_jc_same('SELECT count(*), sum(e.v) FROM iso_jc_ev e JOIN iso_jc_dim d ON d.id = e.dim_id') AS joined, iso_jc_same('SELECT count(*) FROM iso_jc_ev e WHERE NOT EXISTS (SELECT 1 FROM iso_jc_dim d WHERE d.id = e.dim_id)') AS anti; joined|anti ------+---- t |t (1 row) step s2fill: SELECT sift.col_maintain('iso_jc_ev_c') IS NOT NULL AS maintained; maintained ---------- t (1 row) step s2join: SELECT iso_jc_same('SELECT count(*), sum(e.v) FROM iso_jc_ev e JOIN iso_jc_dim d ON d.id = e.dim_id') AS joined, iso_jc_same('SELECT count(*) FROM iso_jc_ev e WHERE NOT EXISTS (SELECT 1 FROM iso_jc_dim d WHERE d.id = e.dim_id)') AS anti; joined|anti ------+---- t |t (1 row) starting permutation: s1set s2set s1pre s2connect s1write s2fill s2join step s1set: SET sift.agg_force = on; SET max_parallel_workers_per_gather = 0; step s2set: SET sift.agg_force = on; SET max_parallel_workers_per_gather = 0; step s1pre: UPDATE iso_jc_dim SET id = id + 1000 WHERE id = 300; DELETE FROM iso_jc_dim WHERE id = 299; step s2connect: CREATE INDEX iso_jc_ev_c ON iso_jc_ev USING sift_col (id, dim_id, v) WITH (connect = 'dim_id -> iso_jc_dim(id)'); step s1write: UPDATE iso_jc_dim SET id = id + 2000 WHERE id <= 5; DELETE FROM iso_jc_dim WHERE id IN (50, 51); INSERT INTO iso_jc_dim VALUES (400, 'new'); step s2fill: SELECT sift.col_maintain('iso_jc_ev_c') IS NOT NULL AS maintained; maintained ---------- t (1 row) step s2join: SELECT iso_jc_same('SELECT count(*), sum(e.v) FROM iso_jc_ev e JOIN iso_jc_dim d ON d.id = e.dim_id') AS joined, iso_jc_same('SELECT count(*) FROM iso_jc_ev e WHERE NOT EXISTS (SELECT 1 FROM iso_jc_dim d WHERE d.id = e.dim_id)') AS anti; joined|anti ------+---- t |t (1 row)