timescaledb/tsl/test/isolation/expected/cagg_concurrent_policy_register.out at 9b5458014d04c7cba949c5cc2821b7a599fdaa23 · gayyappan/timescaledb · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
Parsed test spec with 6 sessions

starting permutation: s1_select s3_lock_before_register s1_run_pol7d_3d_refresh s12_run_pol3d_1d_refresh s13_run_pol1d_refresh s4_enable_before_process_cagg_invalidations s3_release_after_register s5_show_running_jobs s4_release_before_process_cagg_invalidations
step s1_select:
   select min(time) at time zone 'UTC' , max(time) at time zone 'UTC'
   FROM test_3pol_timestamptz;

timezone                |timezone
------------------------+------------------------
Tue May 20 11:05:00 2025|Tue May 27 12:05:00 2025

step s3_lock_before_register:
    -- lock jobs_refresh_ranges table to serialize registration
    BEGIN; LOCK TABLE _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges;

step s1_run_pol7d_3d_refresh:
   DO $$
   DECLARE
     jid integer;
   BEGIN
     SELECT job_id INTO jid FROM cagg_policy_jobs WHERE job_name = 'job_7d_3d';
     CALL run_job(jid);
   END;
   $$;
 <waiting ...>
step s12_run_pol3d_1d_refresh:
   DO $$
   DECLARE
     jid integer;
   BEGIN
     SELECT job_id INTO jid FROM cagg_policy_jobs WHERE job_name = 'job_3d_1d';
     CALL run_job(jid);
   END;
   $$;
 <waiting ...>
step s13_run_pol1d_refresh:
   DO $$
   DECLARE
     jid integer;
   BEGIN
     SELECT job_id INTO jid FROM cagg_policy_jobs WHERE job_name = 'job_1d_1h';
     CALL run_job(jid);
   END;
   $$;
 <waiting ...>
step s4_enable_before_process_cagg_invalidations:
    SELECT debug_waitpoint_enable('before_process_cagg_invalidations_for_refresh_lock');

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


step s3_release_after_register:
   -- release lock on jobs_refresh_ranges table
   ROLLBACK;

step s5_show_running_jobs:
  SELECT ca.user_view_name AS cagg_name, r.start_range, r.end_range,
         to_timestamp(r.start_range / 1000000) AT TIME ZONE 'UTC' AS start_ts_utc,
         to_timestamp(r.end_range / 1000000) AT TIME ZONE 'UTC' AS end_ts_utc
  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, start_range;

cagg_name  |     start_range|       end_range|start_ts_utc            |end_ts_utc
-----------+----------------+----------------+------------------------+------------------------
mat_3pol_m1|1747746000000000|1748091600000000|Tue May 20 13:00:00 2025|Sat May 24 13:00:00 2025
mat_3pol_m1|1748091600000000|1748264400000000|Sat May 24 13:00:00 2025|Mon May 26 13:00:00 2025
mat_3pol_m1|1748264400000000|1748343600000000|Mon May 26 13:00:00 2025|Tue May 27 11:00:00 2025

step s4_release_before_process_cagg_invalidations:
    SELECT debug_waitpoint_release('before_process_cagg_invalidations_for_refresh_lock');

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


step s1_run_pol7d_3d_refresh: <... completed>
step s12_run_pol3d_1d_refresh: <... completed>
step s13_run_pol1d_refresh: <... completed>

starting permutation: s3_lock_before_register s1_run_l2_hist s12_run_l2_recent s4_enable_before_process_cagg_invalidations s3_release_after_register s5_show_running_jobs s4_release_before_process_cagg_invalidations
step s3_lock_before_register:
    -- lock jobs_refresh_ranges table to serialize registration
    BEGIN; LOCK TABLE _timescaledb_catalog.continuous_aggs_jobs_refresh_ranges;

step s1_run_l2_hist:
   DO $$
   DECLARE
     jid integer;
   BEGIN
     SELECT job_id INTO jid FROM cagg_policy_jobs WHERE job_name = 'l2_job_hist';
     CALL run_job(jid);
   END;
   $$;
 <waiting ...>
step s12_run_l2_recent:
   DO $$
   DECLARE
     jid integer;
   BEGIN
     SELECT job_id INTO jid FROM cagg_policy_jobs WHERE job_name = 'l2_job_recent';
     CALL run_job(jid);
   END;
   $$;
 <waiting ...>
step s4_enable_before_process_cagg_invalidations:
    SELECT debug_waitpoint_enable('before_process_cagg_invalidations_for_refresh_lock');

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


step s3_release_after_register:
   -- release lock on jobs_refresh_ranges table
   ROLLBACK;

step s5_show_running_jobs:
  SELECT ca.user_view_name AS cagg_name, r.start_range, r.end_range,
         to_timestamp(r.start_range / 1000000) AT TIME ZONE 'UTC' AS start_ts_utc,
         to_timestamp(r.end_range / 1000000) AT TIME ZONE 'UTC' AS end_ts_utc
  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, start_range;

cagg_name  |        start_range|       end_range|start_ts_utc               |end_ts_utc
-----------+-------------------+----------------+---------------------------+------------------------
mat_2pol_m2|-210866803200000000|1748131200000000|Mon Nov 24 00:00:00 4714 BC|Sun May 25 00:00:00 2025
mat_2pol_m2|   1748131200000000|1748304000000000|Sun May 25 00:00:00 2025   |Tue May 27 00:00:00 2025

step s4_release_before_process_cagg_invalidations:
    SELECT debug_waitpoint_release('before_process_cagg_invalidations_for_refresh_lock');

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


step s1_run_l2_hist: <... completed>
step s12_run_l2_recent: <... completed>