Fix typo in comparing start time

feikesteenbergen · feikesteenbergen · commit 6b4ae13ca9b0 · 2024-12-17T08:36:32.000+01:00
diff --git a/utils/cagg_refresh_producer_consumer/consumer.sql b/utils/cagg_refresh_producer_consumer/consumer.sql
@@ -72,7 +72,7 @@ BEGIN
                         a.finished IS NULL
                         -- If pids ever get recycled (container/machine restart),
                         -- this filter ensures we ignore the old ones
-                        AND started > backend_start
+                        AND started > pg_catalog.pg_postmaster_start_time()
                         AND q.continuous_aggregate = a.continuous_aggregate
                 )
             ORDER BY

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ BEGIN`
`72`	`72`	`a.finished IS NULL`
`73`	`73`	`-- If pids ever get recycled (container/machine restart),`
`74`	`74`	`-- this filter ensures we ignore the old ones`
`75`		`- AND started > backend_start`
	`75`	`+ AND started > pg_catalog.pg_postmaster_start_time()`
`76`	`76`	`AND q.continuous_aggregate = a.continuous_aggregate`
`77`	`77`	`)`
`78`	`78`	`ORDER BY`