diff --git a/synapse/replication/tcp/client.py b/synapse/replication/tcp/client.py index f4c67176b7..3ed3dd3b86 100644 --- a/synapse/replication/tcp/client.py +++ b/synapse/replication/tcp/client.py @@ -439,7 +439,7 @@ class FederationSenderHandler: # The entities are either user IDs (starting with '@') whose devices # have changed, or remote servers that we need to tell about # changes. - if any(row.hosts_calcualted for row in rows): + if any(row.hosts_calculated for row in rows): hosts = await self.store.get_destinations_for_device(token) await self.federation_sender.send_device_messages( hosts, immediate=False diff --git a/synapse/storage/databases/main/devices.py b/synapse/storage/databases/main/devices.py index 76abf1e5ba..5eeca6165d 100644 --- a/synapse/storage/databases/main/devices.py +++ b/synapse/storage/databases/main/devices.py @@ -165,7 +165,7 @@ class DeviceWorkerStore(RoomMemberWorkerStore, EndToEndKeyWorkerStore): ) self._device_list_federation_stream_cache = None - if hs.get_federation_sender() is not None: + if hs.should_send_federation(): ( device_list_federation_prefill, device_list_federation_list_id,