diff options
author | dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> | 2023-02-22 15:29:09 -0500 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-02-22 15:29:09 -0500 |
commit | 9bb2eac71962970d02842bca441f4bcdbbf93a11 (patch) | |
tree | 13b88fe1a0eaa0a02b353623474a8439e5baf46c /synapse/replication | |
parent | Tighten the default rate limit of creating new devices. (#15135) (diff) | |
download | synapse-9bb2eac71962970d02842bca441f4bcdbbf93a11.tar.xz |
Bump black from 22.12.0 to 23.1.0 (#15103)
Diffstat (limited to 'synapse/replication')
-rw-r--r-- | synapse/replication/http/account_data.py | 1 | ||||
-rw-r--r-- | synapse/replication/http/devices.py | 1 | ||||
-rw-r--r-- | synapse/replication/tcp/redis.py | 1 | ||||
-rw-r--r-- | synapse/replication/tcp/streams/events.py | 1 |
4 files changed, 0 insertions, 4 deletions
diff --git a/synapse/replication/http/account_data.py b/synapse/replication/http/account_data.py index 2374f810c9..111ec07e64 100644 --- a/synapse/replication/http/account_data.py +++ b/synapse/replication/http/account_data.py @@ -265,7 +265,6 @@ class ReplicationRemoveTagRestServlet(ReplicationEndpoint): @staticmethod async def _serialize_payload(user_id: str, room_id: str, tag: str) -> JsonDict: # type: ignore[override] - return {} async def _handle_request( # type: ignore[override] diff --git a/synapse/replication/http/devices.py b/synapse/replication/http/devices.py index ecea6fc915..cc3929dcf5 100644 --- a/synapse/replication/http/devices.py +++ b/synapse/replication/http/devices.py @@ -195,7 +195,6 @@ class ReplicationUploadKeysForUserRestServlet(ReplicationEndpoint): async def _serialize_payload( # type: ignore[override] user_id: str, device_id: str, keys: JsonDict ) -> JsonDict: - return { "user_id": user_id, "device_id": device_id, diff --git a/synapse/replication/tcp/redis.py b/synapse/replication/tcp/redis.py index fd1c0ec6af..dfc061eb5e 100644 --- a/synapse/replication/tcp/redis.py +++ b/synapse/replication/tcp/redis.py @@ -328,7 +328,6 @@ class RedisDirectTcpReplicationClientFactory(SynapseRedisFactory): outbound_redis_connection: txredisapi.ConnectionHandler, channel_names: List[str], ): - super().__init__( hs, uuid="subscriber", diff --git a/synapse/replication/tcp/streams/events.py b/synapse/replication/tcp/streams/events.py index 14b6705862..ad9b760713 100644 --- a/synapse/replication/tcp/streams/events.py +++ b/synapse/replication/tcp/streams/events.py @@ -139,7 +139,6 @@ class EventsStream(Stream): current_token: Token, target_row_count: int, ) -> StreamUpdateResult: - # the events stream merges together three separate sources: # * new events # * current_state changes |