diff --git a/synapse/storage/databases/main/stream.py b/synapse/storage/databases/main/stream.py index 6a950f1ba3..cdfff1fc44 100644 --- a/synapse/storage/databases/main/stream.py +++ b/synapse/storage/databases/main/stream.py @@ -524,7 +524,7 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore, metaclass=abc.ABCMeta): [r.event_id for r in rows], get_prev_content=True ) - self._set_before_and_after(ret, rows, topo_order=from_key.stream is None) + self._set_before_and_after(ret, rows, topo_order=False) if order.lower() == "desc": ret.reverse()