diff --git a/synapse/storage/event_federation.py b/synapse/storage/event_federation.py index 7a02bf5e63269b8871c8e7ece9776a1e80c4e648..53feaa19603b48251a3e6df64c5b8f3f6d341406 100644 --- a/synapse/storage/event_federation.py +++ b/synapse/storage/event_federation.py @@ -399,7 +399,7 @@ class EventFederationStore(SQLBaseStore): DELETE FROM stream_ordering_to_exterm WHERE room_id IN ( - SELECT room_id AS stream_ordering + SELECT room_id FROM stream_ordering_to_exterm WHERE stream_ordering > ? ) AND stream_ordering < ?