diff --git a/synapse/rest/admin/__init__.py b/synapse/rest/admin/__init__.py
index 07e0fb71f2..6da1d79168 100644
--- a/synapse/rest/admin/__init__.py
+++ b/synapse/rest/admin/__init__.py
@@ -237,10 +237,12 @@ class PurgeHistoryStatusRestServlet(RestServlet):
raise NotFoundError("purge id '%s' not found" % purge_id)
result: JsonDict = {
- "status": purge_task.status
- if purge_task.status == TaskStatus.COMPLETE
- or purge_task.status == TaskStatus.FAILED
- else "active",
+ "status": (
+ purge_task.status
+ if purge_task.status == TaskStatus.COMPLETE
+ or purge_task.status == TaskStatus.FAILED
+ else "active"
+ ),
}
if purge_task.error:
result["error"] = purge_task.error
diff --git a/synapse/rest/admin/users.py b/synapse/rest/admin/users.py
index a9645e4af7..4e34e46512 100644
--- a/synapse/rest/admin/users.py
+++ b/synapse/rest/admin/users.py
@@ -1184,12 +1184,14 @@ class RateLimitRestServlet(RestServlet):
# convert `null` to `0` for consistency
# both values do the same in retelimit handler
ret = {
- "messages_per_second": 0
- if ratelimit.messages_per_second is None
- else ratelimit.messages_per_second,
- "burst_count": 0
- if ratelimit.burst_count is None
- else ratelimit.burst_count,
+ "messages_per_second": (
+ 0
+ if ratelimit.messages_per_second is None
+ else ratelimit.messages_per_second
+ ),
+ "burst_count": (
+ 0 if ratelimit.burst_count is None else ratelimit.burst_count
+ ),
}
else:
ret = {}
diff --git a/synapse/rest/client/account_data.py b/synapse/rest/client/account_data.py
index 0cdc4cc4f7..12ffca984f 100644
--- a/synapse/rest/client/account_data.py
+++ b/synapse/rest/client/account_data.py
@@ -112,9 +112,9 @@ class AccountDataServlet(RestServlet):
self._hs.config.experimental.msc4010_push_rules_account_data
and account_data_type == AccountDataTypes.PUSH_RULES
):
- account_data: Optional[
- JsonMapping
- ] = await self._push_rules_handler.push_rules_for_user(requester.user)
+ account_data: Optional[JsonMapping] = (
+ await self._push_rules_handler.push_rules_for_user(requester.user)
+ )
else:
account_data = await self.store.get_global_account_data_by_type_for_user(
user_id, account_data_type
diff --git a/synapse/rest/client/sync.py b/synapse/rest/client/sync.py
index 3af2b7dfd9..2b103ca6a8 100644
--- a/synapse/rest/client/sync.py
+++ b/synapse/rest/client/sync.py
@@ -313,12 +313,12 @@ class SyncRestServlet(RestServlet):
# https://github.com/matrix-org/matrix-doc/blob/54255851f642f84a4f1aaf7bc063eebe3d76752b/proposals/2732-olm-fallback-keys.md
# states that this field should always be included, as long as the server supports the feature.
- response[
- "org.matrix.msc2732.device_unused_fallback_key_types"
- ] = sync_result.device_unused_fallback_key_types
- response[
- "device_unused_fallback_key_types"
- ] = sync_result.device_unused_fallback_key_types
+ response["org.matrix.msc2732.device_unused_fallback_key_types"] = (
+ sync_result.device_unused_fallback_key_types
+ )
+ response["device_unused_fallback_key_types"] = (
+ sync_result.device_unused_fallback_key_types
+ )
if joined:
response["rooms"][Membership.JOIN] = joined
@@ -543,9 +543,9 @@ class SyncRestServlet(RestServlet):
if room.unread_thread_notifications:
result["unread_thread_notifications"] = room.unread_thread_notifications
if self._msc3773_enabled:
- result[
- "org.matrix.msc3773.unread_thread_notifications"
- ] = room.unread_thread_notifications
+ result["org.matrix.msc3773.unread_thread_notifications"] = (
+ room.unread_thread_notifications
+ )
result["summary"] = room.summary
if self._msc2654_enabled:
result["org.matrix.msc2654.unread_count"] = room.unread_count
diff --git a/synapse/rest/key/v2/remote_key_resource.py b/synapse/rest/key/v2/remote_key_resource.py
index 6afe4a7bcc..dc7325fc57 100644
--- a/synapse/rest/key/v2/remote_key_resource.py
+++ b/synapse/rest/key/v2/remote_key_resource.py
@@ -191,10 +191,10 @@ class RemoteKey(RestServlet):
server_keys: Dict[Tuple[str, str], Optional[FetchKeyResultForRemote]] = {}
for server_name, key_ids in query.items():
if key_ids:
- results: Mapping[
- str, Optional[FetchKeyResultForRemote]
- ] = await self.store.get_server_keys_json_for_remote(
- server_name, key_ids
+ results: Mapping[str, Optional[FetchKeyResultForRemote]] = (
+ await self.store.get_server_keys_json_for_remote(
+ server_name, key_ids
+ )
)
else:
results = await self.store.get_all_server_keys_json_for_remote(
|
