summary refs log tree commit diff
path: root/synapse/app/generic_worker.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-03-02 12:52:28 +0000
committerErik Johnston <erik@matrix.org>2020-03-02 12:52:28 +0000
commite53744c737527ebb2af94b677b359743473b0434 (patch)
tree92a7c80e2dcfde95bfca62269d736cee73f3266f /synapse/app/generic_worker.py
parentRemove handling of multiple rows per ID (diff)
downloadsynapse-e53744c737527ebb2af94b677b359743473b0434.tar.xz
Fix worker handling
Diffstat (limited to 'synapse/app/generic_worker.py')
-rw-r--r--synapse/app/generic_worker.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/synapse/app/generic_worker.py b/synapse/app/generic_worker.py
index 561a6f4b22..d596852419 100644
--- a/synapse/app/generic_worker.py
+++ b/synapse/app/generic_worker.py
@@ -676,8 +676,9 @@ class GenericWorkerReplicationHandler(ReplicationClientHandler):
             elif stream_name == "device_lists":
                 all_room_ids = set()
                 for row in rows:
-                    room_ids = await self.store.get_rooms_for_user(row.user_id)
-                    all_room_ids.update(room_ids)
+                    if row.entity.startswith("@"):
+                        room_ids = await self.store.get_rooms_for_user(row.entity)
+                        all_room_ids.update(room_ids)
                 self.notifier.on_new_event("device_list_key", token, rooms=all_room_ids)
             elif stream_name == "presence":
                 await self.presence_handler.process_replication_rows(token, rows)