diff options
| author | Richard van der Hoff <richard@matrix.org> | 2020-09-10 10:15:02 +0100 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2020-09-10 10:15:02 +0100 |
| commit | e44e9ee5189bfa9de010276f603fb0bd9ba9bd3b (patch) | |
| tree | de105bae1bb7f590d91b6133bd845156718e67ef /synapse/storage/databases | |
| parent | Do not error when thumbnailing invalid files (#8236) (diff) | |
| parent | 1.20.0rc2 (diff) | |
| download | synapse-e44e9ee5189bfa9de010276f603fb0bd9ba9bd3b.tar.xz | |
Merge branch 'release-v1.20.0' into develop
Diffstat (limited to 'synapse/storage/databases')
| -rw-r--r-- | synapse/storage/databases/main/event_push_actions.py | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/synapse/storage/databases/main/event_push_actions.py b/synapse/storage/databases/main/event_push_actions.py index 50fac9e72e..5233ed83e2 100644 --- a/synapse/storage/databases/main/event_push_actions.py +++ b/synapse/storage/databases/main/event_push_actions.py @@ -196,7 +196,7 @@ class EventPushActionsWorkerStore(SQLBaseStore): def f(txn): sql = ( "SELECT DISTINCT(user_id) FROM event_push_actions WHERE" - " stream_ordering >= ? AND stream_ordering <= ?" + " stream_ordering >= ? AND stream_ordering <= ? AND notif = 1" ) txn.execute(sql, (min_stream_ordering, max_stream_ordering)) return [r[0] for r in txn] @@ -644,7 +644,7 @@ class EventPushActionsWorkerStore(SQLBaseStore): "SELECT e.received_ts" " FROM event_push_actions AS ep" " JOIN events e ON ep.room_id = e.room_id AND ep.event_id = e.event_id" - " WHERE ep.stream_ordering > ?" + " WHERE ep.stream_ordering > ? AND notif = 1" " ORDER BY ep.stream_ordering ASC" " LIMIT 1" ) @@ -708,6 +708,7 @@ class EventPushActionsStore(EventPushActionsWorkerStore): " FROM event_push_actions epa, events e" " WHERE epa.event_id = e.event_id" " AND epa.user_id = ? %s" + " AND epa.notif = 1" " ORDER BY epa.stream_ordering DESC" " LIMIT ?" % (before_clause,) ) |