summary refs log tree commit diff
path: root/synapse/push
diff options
context:
space:
mode:
Diffstat (limited to 'synapse/push')
-rw-r--r--synapse/push/emailpusher.py2
-rw-r--r--synapse/push/httppusher.py4
-rw-r--r--synapse/push/pusherpool.py2
3 files changed, 4 insertions, 4 deletions
diff --git a/synapse/push/emailpusher.py b/synapse/push/emailpusher.py

index 1710dd51b9..877a25071d 100644 --- a/synapse/push/emailpusher.py +++ b/synapse/push/emailpusher.py
@@ -113,7 +113,7 @@ class EmailPusher(Pusher): if self._is_processing: return - run_as_background_process("emailpush.process", self._process) + run_as_background_process("emailpush.process", self._process) # type: ignore[unused-awaitable] def _pause_processing(self) -> None: """Used by tests to temporarily pause processing of events. diff --git a/synapse/push/httppusher.py b/synapse/push/httppusher.py
index b048b03a74..e936baf286 100644 --- a/synapse/push/httppusher.py +++ b/synapse/push/httppusher.py
@@ -160,7 +160,7 @@ class HttpPusher(Pusher): # We could check the receipts are actually m.read receipts here, # but currently that's the only type of receipt anyway... - run_as_background_process("http_pusher.on_new_receipts", self._update_badge) + run_as_background_process("http_pusher.on_new_receipts", self._update_badge) # type: ignore[unused-awaitable] async def _update_badge(self) -> None: # XXX as per https://github.com/matrix-org/matrix-doc/issues/2627, this seems @@ -189,7 +189,7 @@ class HttpPusher(Pusher): if self._is_processing: return - run_as_background_process("httppush.process", self._process) + run_as_background_process("httppush.process", self._process) # type: ignore[unused-awaitable] async def _process(self) -> None: # we should never get here if we are already processing diff --git a/synapse/push/pusherpool.py b/synapse/push/pusherpool.py
index e2648cbc93..d14c9b25bc 100644 --- a/synapse/push/pusherpool.py +++ b/synapse/push/pusherpool.py
@@ -92,7 +92,7 @@ class PusherPool: if not self._should_start_pushers: logger.info("Not starting pushers because they are disabled in the config") return - run_as_background_process("start_pushers", self._start_pushers) + run_as_background_process("start_pushers", self._start_pushers) # type: ignore[unused-awaitable] async def add_or_update_pusher( self,