cagg_concurrent_refresh.out

unused step name: K1_cancelpid
unused step name: R13_refresh1
unused step name: R13_refresh2
unused step name: R13_refresh3
unused step name: R13_refresh4
unused step name: R13_refresh5
unused step name: R1_drop
unused step name: R1_refresh2
unused step name: R2_refresh
unused step name: R2_refresh_exact
unused step name: R2_refresh_superset
unused step name: R5_refresh
unused step name: R6_pending_materialization_ranges
unused step name: R6_pending_materialization_ranges_orphan
Parsed test spec with 15 sessions

starting permutation: R1_refresh S1_select R3_refresh S1_select
step R1_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 25, 70);

step S1_select: 
    SELECT bucket, avg_temp
    FROM cond_10
    ORDER BY 1;

    SELECT * FROM cagg_bucket_count('cond_10');
    SELECT h.table_name AS hypertable, it.watermark AS threshold
    FROM _timescaledb_catalog.continuous_aggs_invalidation_threshold it,
    _timescaledb_catalog.hypertable h
    WHERE it.hypertable_id = h.id
    ORDER BY 1;

bucket|        avg_temp
------+----------------
     0|15.8888888888889
    10|            14.2
    20|            13.4
    30|            18.3
    40|16.0909090909091
    50|            26.9
    60|            18.9

cagg_bucket_count
-----------------
                7

hypertable |  threshold
-----------+-----------
conditions |         70
conditions2|-2147483648

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 70, 107);

step S1_select: 
    SELECT bucket, avg_temp
    FROM cond_10
    ORDER BY 1;

    SELECT * FROM cagg_bucket_count('cond_10');
    SELECT h.table_name AS hypertable, it.watermark AS threshold
    FROM _timescaledb_catalog.continuous_aggs_invalidation_threshold it,
    _timescaledb_catalog.hypertable h
    WHERE it.hypertable_id = h.id
    ORDER BY 1;

bucket|        avg_temp
------+----------------
     0|15.8888888888889
    10|            14.2
    20|            13.4
    30|            18.3
    40|16.0909090909091
    50|            26.9
    60|            18.9
    70|            24.6
    80|            23.6
    90|            21.3

cagg_bucket_count
-----------------
               10

hypertable |  threshold
-----------+-----------
conditions |        100
conditions2|-2147483648


starting permutation: L2_read_lock_threshold_table R3_refresh L2_read_unlock_threshold_table S1_select
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step L2_read_lock_threshold_table: 
    BEGIN;
    LOCK _timescaledb_catalog.continuous_aggs_invalidation_threshold
    IN ACCESS SHARE MODE;

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 70, 107);

step L2_read_unlock_threshold_table: 
    ROLLBACK;

step S1_select: 
    SELECT bucket, avg_temp
    FROM cond_10
    ORDER BY 1;

    SELECT * FROM cagg_bucket_count('cond_10');
    SELECT h.table_name AS hypertable, it.watermark AS threshold
    FROM _timescaledb_catalog.continuous_aggs_invalidation_threshold it,
    _timescaledb_catalog.hypertable h
    WHERE it.hypertable_id = h.id
    ORDER BY 1;

bucket|        avg_temp
------+----------------
     0|15.8888888888889
    10|            14.2
    20|            13.4
    70|            24.6
    80|            23.6
    90|            21.3

cagg_bucket_count
-----------------
                6

hypertable |  threshold
-----------+-----------
conditions |        100
conditions2|-2147483648


starting permutation: R1_refresh L2_read_lock_threshold_table R3_refresh L2_read_unlock_threshold_table S1_select
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step R1_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 25, 70);

step L2_read_lock_threshold_table: 
    BEGIN;
    LOCK _timescaledb_catalog.continuous_aggs_invalidation_threshold
    IN ACCESS SHARE MODE;

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 70, 107);

step L2_read_unlock_threshold_table: 
    ROLLBACK;

step S1_select: 
    SELECT bucket, avg_temp
    FROM cond_10
    ORDER BY 1;

    SELECT * FROM cagg_bucket_count('cond_10');
    SELECT h.table_name AS hypertable, it.watermark AS threshold
    FROM _timescaledb_catalog.continuous_aggs_invalidation_threshold it,
    _timescaledb_catalog.hypertable h
    WHERE it.hypertable_id = h.id
    ORDER BY 1;

bucket|        avg_temp
------+----------------
     0|15.8888888888889
    10|            14.2
    20|            13.4
    30|            18.3
    40|16.0909090909091
    50|            26.9
    60|            18.9
    70|            24.6
    80|            23.6
    90|            21.3

cagg_bucket_count
-----------------
               10

hypertable |  threshold
-----------+-----------
conditions |        100
conditions2|-2147483648


starting permutation: R3_refresh L2_read_lock_threshold_table R1_refresh L2_read_unlock_threshold_table S1_select
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 70, 107);

step L2_read_lock_threshold_table: 
    BEGIN;
    LOCK _timescaledb_catalog.continuous_aggs_invalidation_threshold
    IN ACCESS SHARE MODE;

step R1_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 25, 70);

step L2_read_unlock_threshold_table: 
    ROLLBACK;

step S1_select: 
    SELECT bucket, avg_temp
    FROM cond_10
    ORDER BY 1;

    SELECT * FROM cagg_bucket_count('cond_10');
    SELECT h.table_name AS hypertable, it.watermark AS threshold
    FROM _timescaledb_catalog.continuous_aggs_invalidation_threshold it,
    _timescaledb_catalog.hypertable h
    WHERE it.hypertable_id = h.id
    ORDER BY 1;

bucket|        avg_temp
------+----------------
     0|15.8888888888889
    10|            14.2
    20|            13.4
    30|            18.3
    40|16.0909090909091
    50|            26.9
    60|            18.9
    70|            24.6
    80|            23.6
    90|            21.3

cagg_bucket_count
-----------------
               10

hypertable |  threshold
-----------+-----------
conditions |        100
conditions2|-2147483648


starting permutation: R1_refresh R12_refresh
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step R1_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 25, 70);

step R12_refresh: 
    CALL refresh_continuous_aggregate('cond2_10', 25, 70);


starting permutation: R1_refresh R3_refresh
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step R1_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 25, 70);

step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 70, 107);


starting permutation: WP_after_materialization_enable R1_refresh WP_after_materialization_release R3_refresh
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step WP_after_materialization_enable: 
    SELECT debug_waitpoint_enable('after_process_cagg_materializations');

debug_waitpoint_enable
----------------------
                      

step R1_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 25, 70);
 <waiting ...>
step WP_after_materialization_release: 
    SELECT debug_waitpoint_release('after_process_cagg_materializations');

debug_waitpoint_release
-----------------------
                       

step R1_refresh: <... completed>
step R3_refresh: 
    CALL refresh_continuous_aggregate('cond_10', 70, 107);


starting permutation: WP_after_enable R6_materialization_logs R1_refresh3 R6_materialization_logs RI2_invalidation R2_refresh_left R6_materialization_logs WP_after_release R6_materialization_logs
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step WP_after_enable: 
    SELECT debug_waitpoint_enable('after_process_cagg_invalidations_for_refresh_lock');

debug_waitpoint_enable
----------------------
                      

step R6_materialization_logs: 
    SELECT ca.user_view_name AS cagg,
        lowest_modified_value,
        greatest_modified_value
    FROM _timescaledb_catalog.continuous_aggs_materialization_invalidation_log l
    JOIN _timescaledb_catalog.continuous_agg ca ON ca.mat_hypertable_id = l.materialization_id
    WHERE ca.user_view_name = 'cond_10'
    ORDER BY 1, 2, 3;

cagg   |lowest_modified_value|greatest_modified_value
-------+---------------------+-----------------------
cond_10| -9223372036854775808|                     -1
cond_10|                   30|    9223372036854775807

step R1_refresh3: 
    CALL refresh_continuous_aggregate('cond_10', 60, 70);
 <waiting ...>
step R6_materialization_logs: 
    SELECT ca.user_view_name AS cagg,
        lowest_modified_value,
        greatest_modified_value
    FROM _timescaledb_catalog.continuous_aggs_materialization_invalidation_log l
    JOIN _timescaledb_catalog.continuous_agg ca ON ca.mat_hypertable_id = l.materialization_id
    WHERE ca.user_view_name = 'cond_10'
    ORDER BY 1, 2, 3;

cagg   |lowest_modified_value|greatest_modified_value
-------+---------------------+-----------------------
cond_10| -9223372036854775808|                     -1
cond_10|                    0|                     39
cond_10|                   30|                     59
cond_10|                   60|                     69
cond_10|                   70|    9223372036854775807

step RI2_invalidation: 
    INSERT INTO conditions VALUES  (20, 1000), (30, 1000), (40, 1000), (50, 1000), (60, 1000), (70, 1000), (79, 1000);

step R2_refresh_left: 
    CALL refresh_continuous_aggregate('cond_10', 15, 55);
 <waiting ...>
step R6_materialization_logs: 
    SELECT ca.user_view_name AS cagg,
        lowest_modified_value,
        greatest_modified_value
    FROM _timescaledb_catalog.continuous_aggs_materialization_invalidation_log l
    JOIN _timescaledb_catalog.continuous_agg ca ON ca.mat_hypertable_id = l.materialization_id
    WHERE ca.user_view_name = 'cond_10'
    ORDER BY 1, 2, 3;

cagg   |lowest_modified_value|greatest_modified_value
-------+---------------------+-----------------------
cond_10| -9223372036854775808|                     -1
cond_10|                    0|                     19
cond_10|                   20|                     49
cond_10|                   50|                     79
cond_10|                   60|                     69
cond_10|                   70|    9223372036854775807

step WP_after_release: 
    SELECT debug_waitpoint_release('after_process_cagg_invalidations_for_refresh_lock');

debug_waitpoint_release
-----------------------
                       

step R1_refresh3: <... completed>
step R2_refresh_left: <... completed>
step R6_materialization_logs: 
    SELECT ca.user_view_name AS cagg,
        lowest_modified_value,
        greatest_modified_value
    FROM _timescaledb_catalog.continuous_aggs_materialization_invalidation_log l
    JOIN _timescaledb_catalog.continuous_agg ca ON ca.mat_hypertable_id = l.materialization_id
    WHERE ca.user_view_name = 'cond_10'
    ORDER BY 1, 2, 3;

cagg   |lowest_modified_value|greatest_modified_value
-------+---------------------+-----------------------
cond_10| -9223372036854775808|                     -1
cond_10|                    0|                     19
cond_10|                   50|                     79
cond_10|                   70|    9223372036854775807


starting permutation: WP_before_enable R6_materialization_logs R1_refresh3 R3_refresh_adjacent R6_materialization_logs WP_before_release S1_select R6_materialization_logs
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step WP_before_enable: 
    SELECT debug_waitpoint_enable('before_process_cagg_invalidations_for_refresh_lock');

debug_waitpoint_enable
----------------------
                      

step R6_materialization_logs: 
    SELECT ca.user_view_name AS cagg,
        lowest_modified_value,
        greatest_modified_value
    FROM _timescaledb_catalog.continuous_aggs_materialization_invalidation_log l
    JOIN _timescaledb_catalog.continuous_agg ca ON ca.mat_hypertable_id = l.materialization_id
    WHERE ca.user_view_name = 'cond_10'
    ORDER BY 1, 2, 3;

cagg   |lowest_modified_value|greatest_modified_value
-------+---------------------+-----------------------
cond_10| -9223372036854775808|                     -1
cond_10|                   30|    9223372036854775807

step R1_refresh3: 
    CALL refresh_continuous_aggregate('cond_10', 60, 70);
 <waiting ...>
step R3_refresh_adjacent: 
    CALL refresh_continuous_aggregate('cond_10', 50, 60);
 <waiting ...>
step R6_materialization_logs: 
    SELECT ca.user_view_name AS cagg,
        lowest_modified_value,
        greatest_modified_value
    FROM _timescaledb_catalog.continuous_aggs_materialization_invalidation_log l
    JOIN _timescaledb_catalog.continuous_agg ca ON ca.mat_hypertable_id = l.materialization_id
    WHERE ca.user_view_name = 'cond_10'
    ORDER BY 1, 2, 3;

cagg   |lowest_modified_value|greatest_modified_value
-------+---------------------+-----------------------
cond_10| -9223372036854775808|                     -1
cond_10|                    0|                     39
cond_10|                   30|    9223372036854775807

step WP_before_release: 
    SELECT debug_waitpoint_release('before_process_cagg_invalidations_for_refresh_lock');

debug_waitpoint_release
-----------------------
                       

step R1_refresh3: <... completed>
step R3_refresh_adjacent: <... completed>
step S1_select: 
    SELECT bucket, avg_temp
    FROM cond_10
    ORDER BY 1;

    SELECT * FROM cagg_bucket_count('cond_10');
    SELECT h.table_name AS hypertable, it.watermark AS threshold
    FROM _timescaledb_catalog.continuous_aggs_invalidation_threshold it,
    _timescaledb_catalog.hypertable h
    WHERE it.hypertable_id = h.id
    ORDER BY 1;

bucket|        avg_temp
------+----------------
     0|15.8888888888889
    10|            14.2
    20|            13.4
    50|            26.9
    60|            18.9

cagg_bucket_count
-----------------
                5

hypertable |  threshold
-----------+-----------
conditions |         70
conditions2|-2147483648

step R6_materialization_logs: 
    SELECT ca.user_view_name AS cagg,
        lowest_modified_value,
        greatest_modified_value
    FROM _timescaledb_catalog.continuous_aggs_materialization_invalidation_log l
    JOIN _timescaledb_catalog.continuous_agg ca ON ca.mat_hypertable_id = l.materialization_id
    WHERE ca.user_view_name = 'cond_10'
    ORDER BY 1, 2, 3;

cagg   |lowest_modified_value|greatest_modified_value
-------+---------------------+-----------------------
cond_10| -9223372036854775808|                     -1
cond_10|                    0|                     39
cond_10|                   30|                     49
cond_10|                   70|    9223372036854775807


starting permutation: WP_after_enable R1_refresh3 L4_lock_mat_invals R2_refresh_left WP_after_release L4_unlock_mat_invals S1_select
R5: LOG:  statement: 
    SET SESSION lock_timeout = '500ms';
    SET SESSION deadlock_timeout = '500ms';
    SET SESSION client_min_messages = 'DEBUG1';

step WP_after_enable: 
    SELECT debug_waitpoint_enable('after_process_cagg_invalidations_for_refresh_lock');

debug_waitpoint_enable
----------------------
                      

step R1_refresh3: 
    CALL refresh_continuous_aggregate('cond_10', 60, 70);
 <waiting ...>
step L4_lock_mat_invals: 
    BEGIN;
    LOCK _timescaledb_catalog.continuous_aggs_materialization_invalidation_log
    IN ACCESS EXCLUSIVE MODE;

step R2_refresh_left: 
    CALL refresh_continuous_aggregate('cond_10', 15, 55);
 <waiting ...>
step WP_after_release: 
    SELECT debug_waitpoint_release('after_process_cagg_invalidations_for_refresh_lock');

debug_waitpoint_release
-----------------------
                       

step L4_unlock_mat_invals: 
    ROLLBACK;

step R1_refresh3: <... completed>
step R2_refresh_left: <... completed>
step S1_select: 
    SELECT bucket, avg_temp
    FROM cond_10
    ORDER BY 1;

    SELECT * FROM cagg_bucket_count('cond_10');
    SELECT h.table_name AS hypertable, it.watermark AS threshold
    FROM _timescaledb_catalog.continuous_aggs_invalidation_threshold it,
    _timescaledb_catalog.hypertable h
    WHERE it.hypertable_id = h.id
    ORDER BY 1;

bucket|        avg_temp
------+----------------
     0|15.8888888888889
    10|            14.2
    20|14.2380952380952
    30|            18.3
    40|16.0909090909091
    60|            18.9

cagg_bucket_count
-----------------
                6

hypertable |  threshold
-----------+-----------
conditions |         70
conditions2|-2147483648