diff options
| author | Erik Johnston <erik@matrix.org> | 2018-06-01 15:05:07 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2018-06-01 15:05:07 +0100 |
| commit | f4eb10533e7863aaa0e12c688cf272b54eda8b02 (patch) | |
| tree | dab2c2da21510b19908691cbbd072ad05c17fee9 | |
| parent | use farey function (diff) | |
| download | synapse-f4eb10533e7863aaa0e12c688cf272b54eda8b02.tar.xz | |
fixup
| -rw-r--r-- | synapse/storage/events.py | 2 | ||||
| -rw-r--r-- | synapse/storage/stream.py | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index 5ab9b302e2..72a35679db 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -1449,7 +1449,7 @@ class EventsStore(EventsWorkerStore): sibling_events.update(pes) table = ChunkDBOrderedListStore( - txn, room_id, self.clock, + txn, room_id, self.clock, self.database_engine, ) # If there is only one previous chunk (and that isn't None), then this diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py index fd59c2d318..379f45a56d 100644 --- a/synapse/storage/stream.py +++ b/synapse/storage/stream.py @@ -810,7 +810,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore): iterated_chunks = [chunk_id] table = ChunkDBOrderedListStore( - txn, room_id, self.clock, + txn, room_id, self.clock, self.database_engine, ) while chunk_id and (limit <= 0 or len(rows) < limit): |