diff options
| author | Hubert Chathi <hubert@uhoreg.ca> | 2019-10-30 14:57:34 -0400 |
|---|---|---|
| committer | Hubert Chathi <hubert@uhoreg.ca> | 2019-10-30 14:57:34 -0400 |
| commit | bb6cec27a5ac6d5d6d5f67df21610a63745ac0a9 (patch) | |
| tree | 20fe45ccc7c8371e10ab8dc7eca9fcadd8da63bc /synapse/federation/sender | |
| parent | Merge branch 'develop' into cross-signing_federation (diff) | |
| download | synapse-bb6cec27a5ac6d5d6d5f67df21610a63745ac0a9.tar.xz | |
rename get_devices_by_remote to get_device_updates_by_remote
Diffstat (limited to 'synapse/federation/sender')
| -rw-r--r-- | synapse/federation/sender/per_destination_queue.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/federation/sender/per_destination_queue.py b/synapse/federation/sender/per_destination_queue.py index d5d4a60c88..6e3012cd41 100644 --- a/synapse/federation/sender/per_destination_queue.py +++ b/synapse/federation/sender/per_destination_queue.py @@ -359,7 +359,7 @@ class PerDestinationQueue(object): last_device_list = self._last_device_list_stream_id # Retrieve list of new device updates to send to the destination - now_stream_id, results = yield self._store.get_devices_by_remote( + now_stream_id, results = yield self._store.get_device_updates_by_remote( self._destination, last_device_list, limit=limit ) edus = [ @@ -372,7 +372,7 @@ class PerDestinationQueue(object): for (edu_type, content) in results ] - assert len(edus) <= limit, "get_devices_by_remote returned too many EDUs" + assert len(edus) <= limit, "get_device_updates_by_remote returned too many EDUs" return (edus, now_stream_id) |