diff options
| author | David Baker <dave@matrix.org> | 2016-04-07 17:33:37 +0100 |
|---|---|---|
| committer | David Baker <dave@matrix.org> | 2016-04-07 17:33:37 +0100 |
| commit | 3fb35cbd6fc52905c88344fd3ea55a4ee1d1c478 (patch) | |
| tree | 747631efdb7b8dcfdf51c2394c6354529d69d791 | |
| parent | Wrap process in a flag so we don't process whist already processing. (diff) | |
| download | synapse-3fb35cbd6fc52905c88344fd3ea55a4ee1d1c478.tar.xz | |
Oops, inequality fail
| -rw-r--r-- | synapse/storage/event_push_actions.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/storage/event_push_actions.py b/synapse/storage/event_push_actions.py index 4d72e4a85e..355478957d 100644 --- a/synapse/storage/event_push_actions.py +++ b/synapse/storage/event_push_actions.py @@ -105,7 +105,7 @@ class EventPushActionsStore(SQLBaseStore): def f(txn): sql = ( "SELECT DISTINCT(user_id) FROM event_push_actions WHERE" - " stream_ordering >= ? AND stream_ordering >= ?" + " stream_ordering >= ? AND stream_ordering <= ?" ) txn.execute(sql, (min_stream_ordering, max_stream_ordering)) return [r[0] for r in txn.fetchall()] |