summary refs log tree commit diff
path: root/synapse/replication/tcp/redis.py
diff options
context:
space:
mode:
authorMathieu Velten <mathieuv@matrix.org>2022-11-22 14:44:09 +0100
committerMathieu Velten <mathieuv@matrix.org>2022-11-22 18:09:13 +0100
commita0dfa69ffc2474fcd433597b23c74a98ec45840a (patch)
tree0aaf5532543e20b4118ddca0ede25aebccb688a7 /synapse/replication/tcp/redis.py
parentEnable unused awaitable error in mypy (diff)
downloadsynapse-a0dfa69ffc2474fcd433597b23c74a98ec45840a.tar.xz
Add type ignore unused-awaitable to run_as_background_process calls
Diffstat (limited to 'synapse/replication/tcp/redis.py')
-rw-r--r--synapse/replication/tcp/redis.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/synapse/replication/tcp/redis.py b/synapse/replication/tcp/redis.py

index fd1c0ec6af..450a14ff17 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) + 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( + 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( + run_as_background_process( # type: ignore[unused-awaitable] "send-cmd", self._async_send_command, cmd, bg_start_span=False )