diff options
| author | Erik Johnston <erik@matrix.org> | 2015-05-21 15:40:22 +0100 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2015-05-21 15:40:22 +0100 |
| commit | 73d23c6ae85b180dbeca070fc9149692ee2fbcfe (patch) | |
| tree | e1f1c8f3892ba6f61d51b2ab2968609c0b5417a7 | |
| parent | PriorityQueue gives lowest first (diff) | |
| download | synapse-73d23c6ae85b180dbeca070fc9149692ee2fbcfe.tar.xz | |
Don't readd things that are already in event_results
| -rw-r--r-- | synapse/storage/event_federation.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/synapse/storage/event_federation.py b/synapse/storage/event_federation.py index 03942fec7a..a3da117799 100644 --- a/synapse/storage/event_federation.py +++ b/synapse/storage/event_federation.py @@ -411,7 +411,8 @@ class EventFederationStore(SQLBaseStore): ) for row in txn.fetchall(): - queue.put((-row[0], row[1])) + if row[1] not in event_results: + queue.put((-row[0], row[1])) return event_results |