Fix aggregation query offset

Fizzadar · Fizzadar · commit 47eccd0e0b2d · 2023-01-16T17:33:37.000Z
diff --git a/synapse/storage/databases/main/beeper.py b/synapse/storage/databases/main/beeper.py
@@ -178,8 +178,10 @@ def aggregate_txn(txn: LoggingTransaction) -> None:
                         event_stream_ordering > (
                             SELECT event_stream_ordering FROM beeper_user_notification_counts_stream_ordering
                         )
-                        -- Arbitrary 100k offset for now
-                        AND event_stream_ordering < SELECT MAX(stream_ordering) - 100000 FROM events
+                        AND event_stream_ordering < (
+                            -- Arbitrary 100k offset for now
+                            SELECT MAX(stream_ordering) - 100000 FROM events
+                        )
                 )
                 UPDATE
                     beeper_user_notification_counts AS epc

Original file line number	Diff line number	Diff line change
`@@ -178,8 +178,10 @@ def aggregate_txn(txn: LoggingTransaction) -> None:`
`178`	`178`	`event_stream_ordering > (`
`179`	`179`	`SELECT event_stream_ordering FROM beeper_user_notification_counts_stream_ordering`
`180`	`180`	`)`
`181`		`- -- Arbitrary 100k offset for now`
`182`		`- AND event_stream_ordering < SELECT MAX(stream_ordering) - 100000 FROM events`
	`181`	`+ AND event_stream_ordering < (`
	`182`	`+ -- Arbitrary 100k offset for now`
	`183`	`+ SELECT MAX(stream_ordering) - 100000 FROM events`
	`184`	`+ )`
`183`	`185`	`)`
`184`	`186`	`UPDATE`
`185`	`187`	`beeper_user_notification_counts AS epc`