tweak

Author: feikesteenbergen

utils/cagg_refresh_producer_consumer/consumer.sql

@@ -16,7 +16,7 @@ BEGIN
         SET LOCAL lock_timeout TO '1 min';
 
         -- Prevent a hot loop
-        PERFORM pg_catalog.pg_sleep(0.9);
+        PERFORM pg_catalog.pg_sleep(0.2);
 
         DECLARE
             p_id bigint;
@@ -104,11 +104,13 @@ BEGIN
                 id = p_id;
             COMMIT;
 
-            RAISE NOTICE 'Processing %, (% - %)', p_cagg, p_window_start, p_window_end;
+            RAISE NOTICE
+                '% - Processing %, (% - %)',
+                pg_catalog.to_char(pg_catalog.clock_timestamp(), 'YYYY-MM-DD HH24:MI:SS.FF3OF'),
+                p_cagg,
+                p_window_start,
+                p_window_end;
         END;
-
-        RAISE NOTICE 'Hi!';
-        PERFORM pg_catalog.pg_sleep(1);
     END LOOP;
 
     RAISE NOTICE 'Shutting down worker, as we exceeded our maximum runtime (%)', max_runtime;

utils/cagg_refresh_producer_consumer/example.sql

@@ -11,7 +11,4 @@ CALL _timescaledb_additional.schedule_refresh_continuous_aggregate_incremental(
 }'
 );
 
-CALL _timescaledb_additional.task_refresh_continuous_aggregate_incremental_runner(
-    job_id => null,
-    config =>'{"max_runtime": "3 minutes"}'
-);
+--CALL _timescaledb_additional.task_refresh_continuous_aggregate_incremental_runner(null, null);

utils/cagg_refresh_producer_consumer/producer.sql

@@ -32,7 +32,12 @@ CREATE UNIQUE INDEX IF NOT EXISTS incr_cagg_refreshes_distinct_tasks_unq ON _tim
     window_end
 ) WHERE worker_pid IS NULL AND finished IS NULL;
 
-CREATE INDEX IF NOT EXISTS incr_cagg_refreshes_active_workers ON _timescaledb_additional.incremental_continuous_aggregate_refreshes(
+CREATE INDEX IF NOT EXISTS incr_cagg_refreshes_find_first_work_item_idx ON _timescaledb_additional.incremental_continuous_aggregate_refreshes(
+    priority,
+    scheduled
+) WHERE worker_pid IS NULL;
+
+CREATE INDEX IF NOT EXISTS incr_cagg_refreshes_active_workers_idx ON _timescaledb_additional.incremental_continuous_aggregate_refreshes(
     worker_pid
 ) WHERE worker_pid IS NOT NULL;