diff options
| author | Mathieu Velten <mathieuv@matrix.org> | 2022-11-22 18:10:40 +0100 |
|---|---|---|
| committer | Mathieu Velten <mathieuv@matrix.org> | 2022-11-22 18:10:40 +0100 |
| commit | 53ca28a657b18f273495c951d607e9d36ed10943 (patch) | |
| tree | decc2c888f9804ab0d325192cf51f3754f322d9e /synapse/push | |
| parent | Add type ignore unused-awaitable to LoopingCall start call (diff) | |
| download | synapse-53ca28a657b18f273495c951d607e9d36ed10943.tar.xz | |
Reformat
Diffstat (limited to 'synapse/push')
| -rw-r--r-- | synapse/push/emailpusher.py | 2 | ||||
| -rw-r--r-- | synapse/push/httppusher.py | 4 | ||||
| -rw-r--r-- | synapse/push/pusherpool.py | 4 |
3 files changed, 5 insertions, 5 deletions
diff --git a/synapse/push/emailpusher.py b/synapse/push/emailpusher.py index 877a25071d..8b8615673f 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) # type: ignore[unused-awaitable] + 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 e936baf286..5d65194c42 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) # type: ignore[unused-awaitable] + 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) # type: ignore[unused-awaitable] + 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 d9589f76f9..4e1bec1110 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) # type: ignore[unused-awaitable] + run_as_background_process("start_pushers", self._start_pushers) # type: ignore[unused-awaitable] async def add_or_update_pusher( self, @@ -236,7 +236,7 @@ class PusherPool: # We only start a new background process if necessary rather than # optimistically (to cut down on overhead). - self._on_new_notifications(max_token) # type: ignore[unused-awaitable] + self._on_new_notifications(max_token) # type: ignore[unused-awaitable] @wrap_as_background_process("on_new_notifications") async def _on_new_notifications(self, max_token: RoomStreamToken) -> None: |