Remove spurious break

2018-06-01 11:54:24 +01:00
parent e7bb34b72a
commit 58aadd3dd4
1 changed files with 0 additions and 3 deletions
--- a/synapse/storage/stream.py
+++ b/synapse/storage/stream.py
@@ -826,9 +826,6 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
            txn.execute(sql, args)
            new_rows = [_EventDictReturn(*row) for row in txn]

-            if not new_rows:
-                break
-
            rows.extend(new_rows)

        if limit > 0: