diff options
| -rw-r--r-- | synapse/storage/events.py | 19 |
1 files changed, 6 insertions, 13 deletions
diff --git a/synapse/storage/events.py b/synapse/storage/events.py index 2f648111b3..cad5086f5f 100644 --- a/synapse/storage/events.py +++ b/synapse/storage/events.py @@ -1503,24 +1503,17 @@ class EventsStore(EventsWorkerStore): retcol="chunk_id", ) - prev_chunk_ids = set( - pid for pid in prev_chunk_ids - if pid is not None and pid not in current_prev_ids and pid != chunk_id - ) - forward_chunk_ids = set( - fid for fid in forward_chunk_ids - if fid not in current_forward_ids and fid != chunk_id - ) - for pid in prev_chunk_ids: - # Note that the edge direction is reversed than what you might - # expect. See ChunkDBOrderedListStore for more details. - table.add_edge(pid, chunk_id) + if pid is not None and pid not in current_prev_ids and pid != chunk_id: + # Note that the edge direction is reversed than what you might + # expect. See ChunkDBOrderedListStore for more details. + table.add_edge(pid, chunk_id) for fid in forward_chunk_ids: # Note that the edge direction is reversed than what you might # expect. See ChunkDBOrderedListStore for more details. - table.add_edge(chunk_id, fid) + if fid not in current_forward_ids and fid != chunk_id: + table.add_edge(chunk_id, fid) # We now need to update the backwards extremities for the chunks. |