diff options
| author | Erik Johnston <erik@matrix.org> | 2020-03-02 12:52:28 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-03-02 12:52:28 +0000 |
| commit | e53744c737527ebb2af94b677b359743473b0434 (patch) | |
| tree | 92a7c80e2dcfde95bfca62269d736cee73f3266f /synapse/app/generic_worker.py | |
| parent | Remove handling of multiple rows per ID (diff) | |
| download | synapse-e53744c737527ebb2af94b677b359743473b0434.tar.xz | |
Fix worker handling
Diffstat (limited to 'synapse/app/generic_worker.py')
| -rw-r--r-- | synapse/app/generic_worker.py | 5 |
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) |