cagg_refresh_cleanup_register.out

Parsed test spec with 9 sessions

starting permutation: WP_mat_enable R2_refresh L1_lock WP_mat_disable R3_refresh R4_refresh check_locks check_jobs L1_unlock check_locks check_jobs
step WP_mat_enable: SELECT debug_waitpoint_enable('after_process_cagg_materializations');
debug_waitpoint_enable
----------------------
                      

step R2_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-01-05', '2026-02-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step L1_lock: 
    BEGIN;
    LOCK TABLE _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges
        IN ACCESS EXCLUSIVE MODE;

step WP_mat_disable: SELECT debug_waitpoint_release('after_process_cagg_materializations');
debug_waitpoint_release
-----------------------
                       

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-02-15', '2026-03-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step R4_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-03-15', '2026-03-30', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step check_locks: 
    SELECT l.mode, l.granted
    FROM pg_locks l
    JOIN pg_class c ON c.oid = l.relation
    WHERE c.relname = 'continuous_aggs_jobs_refresh_ranges'
    ORDER BY l.mode;

mode                    |granted
------------------------+-------
AccessExclusiveLock     |t      
RowExclusiveLock        |f      
ShareUpdateExclusiveLock|f      
ShareUpdateExclusiveLock|f      

step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time                  |end_time                    
--------------+----------------------------+----------------------------
cond_daily    |Mon Jan 05 16:00:00 2026 PST|Sat Feb 14 16:00:00 2026 PST

step L1_unlock: 
    COMMIT;
 <waiting ...>
step R2_refresh: <... completed>
step R3_refresh: <... completed>
step R4_refresh: <... completed>
step L1_unlock: <... completed>
step check_locks: 
    SELECT l.mode, l.granted
    FROM pg_locks l
    JOIN pg_class c ON c.oid = l.relation
    WHERE c.relname = 'continuous_aggs_jobs_refresh_ranges'
    ORDER BY l.mode;

mode|granted
----+-------

step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time|end_time
--------------+----------+--------


starting permutation: WP_mat_enable R2_refresh L1_lock WP_mat_disable R3_refresh R4_overlapping_refresh check_locks check_jobs L1_unlock check_locks check_jobs
step WP_mat_enable: SELECT debug_waitpoint_enable('after_process_cagg_materializations');
debug_waitpoint_enable
----------------------
                      

step R2_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-01-05', '2026-02-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step L1_lock: 
    BEGIN;
    LOCK TABLE _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges
        IN ACCESS EXCLUSIVE MODE;

step WP_mat_disable: SELECT debug_waitpoint_release('after_process_cagg_materializations');
debug_waitpoint_release
-----------------------
                       

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-02-15', '2026-03-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step R4_overlapping_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-03-01', '2026-03-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step check_locks: 
    SELECT l.mode, l.granted
    FROM pg_locks l
    JOIN pg_class c ON c.oid = l.relation
    WHERE c.relname = 'continuous_aggs_jobs_refresh_ranges'
    ORDER BY l.mode;

mode                    |granted
------------------------+-------
AccessExclusiveLock     |t      
RowExclusiveLock        |f      
ShareUpdateExclusiveLock|f      
ShareUpdateExclusiveLock|f      

step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time                  |end_time                    
--------------+----------------------------+----------------------------
cond_daily    |Mon Jan 05 16:00:00 2026 PST|Sat Feb 14 16:00:00 2026 PST

step L1_unlock: 
    COMMIT;
 <waiting ...>
step R2_refresh: <... completed>
step R3_refresh: <... completed>
step R4_overlapping_refresh: <... completed>
ERROR:  could not refresh continuous aggregate "cond_daily" due to a concurrent refresh
step L1_unlock: <... completed>
step check_locks: 
    SELECT l.mode, l.granted
    FROM pg_locks l
    JOIN pg_class c ON c.oid = l.relation
    WHERE c.relname = 'continuous_aggs_jobs_refresh_ranges'
    ORDER BY l.mode;

mode|granted
----+-------

step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time|end_time
--------------+----------+--------


starting permutation: WP_before_txn2_start_enable R3_refresh check_jobs A1_revoke_perm WP_before_txn2_start_disable check_jobs
step WP_before_txn2_start_enable: SELECT debug_waitpoint_enable('cagg_refresh_after_register');
debug_waitpoint_enable
----------------------
                      

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-02-15', '2026-03-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time                  |end_time                    
--------------+----------------------------+----------------------------
cond_daily    |Sun Feb 15 16:00:00 2026 PST|Sat Mar 14 17:00:00 2026 PDT

step A1_revoke_perm: 
  REVOKE SELECT on conditions FROM cagg_user;

step WP_before_txn2_start_disable: SELECT debug_waitpoint_release('cagg_refresh_after_register');
debug_waitpoint_release
-----------------------
                       

step R3_refresh: <... completed>
ERROR:  permission denied for table conditions
step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time|end_time
--------------+----------+--------


starting permutation: WP_before_txn3_start_enable R3_refresh check_jobs A1_revoke_mat_perm WP_before_txn3_start_disable check_jobs
step WP_before_txn3_start_enable: SELECT debug_waitpoint_enable('after_process_cagg_invalidations_for_refresh_lock');
debug_waitpoint_enable
----------------------
                      

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-02-15', '2026-03-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time                  |end_time                    
--------------+----------------------------+----------------------------
cond_daily    |Sun Feb 15 16:00:00 2026 PST|Sat Mar 14 17:00:00 2026 PDT

step A1_revoke_mat_perm: 
  DO $$
  DECLARE
      mat_ht text;
  BEGIN
      SELECT format('%I.%I', h.schema_name, h.table_name)::regclass
        INTO mat_ht
        FROM _timescaledb_catalog.continuous_agg ca
        JOIN _timescaledb_catalog.hypertable h ON h.id = ca.mat_hypertable_id
       WHERE ca.user_view_name = 'cond_daily';
      EXECUTE format('REVOKE SELECT ON %s FROM cagg_user', mat_ht);
  END;
  $$;

step WP_before_txn3_start_disable: SELECT debug_waitpoint_release('after_process_cagg_invalidations_for_refresh_lock');
debug_waitpoint_release
-----------------------
                       

step R3_refresh: <... completed>
ERROR:  permission denied for table _materialized_hypertable_X
step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time|end_time
--------------+----------+--------


starting permutation: WP_after_register_enable R2_refresh check_jobs_metadata_manual WP_after_register_disable
step WP_after_register_enable: SELECT debug_waitpoint_enable('cagg_refresh_after_register');
debug_waitpoint_enable
----------------------
                      

step R2_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-01-05', '2026-02-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step check_jobs_metadata_manual: 
    SELECT ca.user_view_name,
           r.job_id = 0 AS has_zero_job_id,
           r.created_at IS NOT NULL AS has_created_at
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|has_zero_job_id|has_created_at
--------------+---------------+--------------
cond_daily    |t              |t             

step WP_after_register_disable: SELECT debug_waitpoint_release('cagg_refresh_after_register');
debug_waitpoint_release
-----------------------
                       

step R2_refresh: <... completed>

starting permutation: P1_add_policy WP_after_register_enable P1_run_policy check_jobs_metadata_policy WP_after_register_disable
step P1_add_policy: 
    SELECT 1 AS policy_created FROM add_continuous_aggregate_policy(
        'cond_daily',
        start_offset => NULL,
        end_offset => NULL,
        schedule_interval => INTERVAL '1 h'
    );

policy_created
--------------
             1

step WP_after_register_enable: SELECT debug_waitpoint_enable('cagg_refresh_after_register');
debug_waitpoint_enable
----------------------
                      

step P1_run_policy: 
    DO $$
    DECLARE
        jid int;
    BEGIN
        SELECT job_id INTO jid FROM timescaledb_information.jobs
        WHERE hypertable_name = 'cond_daily'
        AND proc_name = 'policy_refresh_continuous_aggregate';
        CALL run_job(jid);
    END;
    $$;
 <waiting ...>
step check_jobs_metadata_policy: 
    SELECT ca.user_view_name,
           r.job_id != 0 AS has_non_zero_job_id,
           r.created_at IS NOT NULL AS has_created_at
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|has_non_zero_job_id|has_created_at
--------------+-------------------+--------------
cond_daily    |t                  |t             

step WP_after_register_disable: SELECT debug_waitpoint_release('cagg_refresh_after_register');
debug_waitpoint_release
-----------------------
                       

step P1_run_policy: <... completed>

starting permutation: WP_before_txn2_commit_enable R1_refresh check_jobs K1_terminate WP_before_txn2_commit_disable L1_lock R2_refresh R3_refresh L1_unlock check_jobs
step WP_before_txn2_commit_enable: SELECT debug_waitpoint_enable('before_process_cagg_invalidations_for_refresh_lock');
debug_waitpoint_enable
----------------------
                      

step R1_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-01-05', '2026-03-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time                  |end_time                    
--------------+----------------------------+----------------------------
cond_daily    |Mon Jan 05 16:00:00 2026 PST|Sat Mar 14 17:00:00 2026 PDT

step K1_terminate: 
    CALL terminate_r1();
 <waiting ...>
step R1_refresh: <... completed>
FATAL:  terminating connection due to administrator command
server closed the connection unexpectedly
	This probably means the server terminated abnormally
	before or while processing the request.

step WP_before_txn2_commit_disable: SELECT debug_waitpoint_release('before_process_cagg_invalidations_for_refresh_lock');
debug_waitpoint_release
-----------------------
                       

step K1_terminate: <... completed>
step L1_lock: 
    BEGIN;
    LOCK TABLE _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges
        IN ACCESS EXCLUSIVE MODE;

step R2_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-01-05', '2026-02-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_daily', '2026-02-15', '2026-03-15', options => jsonb_build_object('buckets_per_batch', 0));
 <waiting ...>
step L1_unlock: 
    COMMIT;
 <waiting ...>
step R2_refresh: <... completed>
step R3_refresh: <... completed>
step L1_unlock: <... completed>
step check_jobs: 
    SELECT ca.user_view_name,
           _timescaledb_functions.to_timestamp(r.start_range) AS start_time,
           _timescaledb_functions.to_timestamp(r.end_range) AS end_time
    FROM _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges r
    JOIN _timescaledb_catalog.continuous_agg ca
        ON r.materialization_id = ca.mat_hypertable_id
    ORDER BY ca.user_view_name, r.start_range;

user_view_name|start_time|end_time
--------------+----------+--------