diff options
| author | Brendan Abolivier <babolivier@matrix.org> | 2019-10-30 17:28:41 +0000 |
|---|---|---|
| committer | Brendan Abolivier <babolivier@matrix.org> | 2019-10-30 17:28:41 +0000 |
| commit | fe51d6cacf6e1a2da5fc3589d0bc4118342b33dd (patch) | |
| tree | 98ba7e3838518a0053015eec259f932bbb299cd8 /synapse/storage/data_stores | |
| parent | Add integration tests for sync (diff) | |
| download | synapse-fe51d6cacf6e1a2da5fc3589d0bc4118342b33dd.tar.xz | |
Add more integration testing
Diffstat (limited to 'synapse/storage/data_stores')
| -rw-r--r-- | synapse/storage/data_stores/main/stream.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/storage/data_stores/main/stream.py b/synapse/storage/data_stores/main/stream.py index 907d7f20ba..cfa34ba1e7 100644 --- a/synapse/storage/data_stores/main/stream.py +++ b/synapse/storage/data_stores/main/stream.py @@ -872,7 +872,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore): args.append(int(limit)) sql = ( - "SELECT event_id, topological_ordering, stream_ordering" + "SELECT DISTINCT event_id, topological_ordering, stream_ordering" " FROM events" " LEFT JOIN event_labels USING (event_id)" " WHERE outlier = ? AND room_id = ? AND %(bounds)s" |