From f4eb10533e7863aaa0e12c688cf272b54eda8b02 Mon Sep 17 00:00:00 2001 From: Erik Johnston Date: Fri, 1 Jun 2018 15:05:07 +0100 Subject: [PATCH] fixup --- synapse/storage/events.py | 2 +- 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):