summary refs log tree commit diff
path: root/synapse/storage/devices.py
diff options
context:
space:
mode:
authorHubert Chathi <hubert@uhoreg.ca>2019-08-21 13:19:35 -0700
committerHubert Chathi <hubert@uhoreg.ca>2019-08-21 13:19:35 -0700
commit7c3abc65728af052b0d484f9669b1c084cd2faf5 (patch)
tree57b7c1e56476b35515d9146698648a4b4820c6bc /synapse/storage/devices.py
parentfix formatting (diff)
downloadsynapse-7c3abc65728af052b0d484f9669b1c084cd2faf5.tar.xz
apply PR review suggestions
Diffstat (limited to 'synapse/storage/devices.py')
-rw-r--r--synapse/storage/devices.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/storage/devices.py b/synapse/storage/devices.py
index da23a350a1..6a5572e001 100644
--- a/synapse/storage/devices.py
+++ b/synapse/storage/devices.py
@@ -317,7 +317,7 @@ class DeviceWorkerStore(SQLBaseStore):
                 user_ids,
                 stream_id,
             )
-        defer.returnValue(stream_id)
+        return stream_id
 
     def _add_user_signature_change_txn(self, txn, from_user_id, user_ids, stream_id):
         txn.call_after(
@@ -491,9 +491,9 @@ class DeviceWorkerStore(SQLBaseStore):
             rows = yield self._execute(
                 "get_users_whose_signatures_changed", None, sql, user_id, from_key
             )
-            defer.returnValue(set(user for row in rows for user in json.loads(row[0])))
+            return set(user for row in rows for user in json.loads(row[0]))
         else:
-            defer.returnValue(set())
+            return set()
 
     def get_all_device_list_changes_for_remotes(self, from_key, to_key):
         """Return a list of `(stream_id, user_id, destination)` which is the