From 53ca28a657b18f273495c951d607e9d36ed10943 Mon Sep 17 00:00:00 2001 From: Mathieu Velten Date: Tue, 22 Nov 2022 18:10:40 +0100 Subject: Reformat --- synapse/replication/tcp/redis.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) (limited to 'synapse/replication/tcp/redis.py') diff --git a/synapse/replication/tcp/redis.py b/synapse/replication/tcp/redis.py index 450a14ff17..c5b0bb4e1f 100644 --- a/synapse/replication/tcp/redis.py +++ b/synapse/replication/tcp/redis.py @@ -112,7 +112,7 @@ class RedisSubscriber(txredisapi.SubscriberProtocol): def connectionMade(self) -> None: logger.info("Connected to redis") super().connectionMade() - run_as_background_process("subscribe-replication", self._send_subscribe) # type: ignore[unused-awaitable] + run_as_background_process("subscribe-replication", self._send_subscribe) # type: ignore[unused-awaitable] async def _send_subscribe(self) -> None: # it's important to make sure that we only send the REPLICATE command once we @@ -183,7 +183,7 @@ class RedisSubscriber(txredisapi.SubscriberProtocol): # if so. if isawaitable(res): - run_as_background_process( # type: ignore[unused-awaitable] + run_as_background_process( # type: ignore[unused-awaitable] "replication-" + cmd.get_logcontext_id(), lambda: res ) @@ -205,7 +205,7 @@ class RedisSubscriber(txredisapi.SubscriberProtocol): Args: cmd: The command to send """ - run_as_background_process( # type: ignore[unused-awaitable] + run_as_background_process( # type: ignore[unused-awaitable] "send-cmd", self._async_send_command, cmd, bg_start_span=False ) -- cgit 1.5.1