diff options
| author | Erik Johnston <erik@matrix.org> | 2021-02-22 21:14:42 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-02-22 21:14:42 +0000 |
| commit | 66f4949e7f57bad44c582098f702fda057c6c7ad (patch) | |
| tree | 40bbcfa9a4dad789f5cbc51c5d523c3f084ef48e /synapse/push/httppusher.py | |
| parent | Remove vestiges of uploads_path config (#9462) (diff) | |
| download | synapse-66f4949e7f57bad44c582098f702fda057c6c7ad.tar.xz | |
Fix deleting pushers when using sharded pushers. (#9465)
Diffstat (limited to 'synapse/push/httppusher.py')
| -rw-r--r-- | synapse/push/httppusher.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/synapse/push/httppusher.py b/synapse/push/httppusher.py index b9d3da2e0a..f4d7e199e9 100644 --- a/synapse/push/httppusher.py +++ b/synapse/push/httppusher.py @@ -74,6 +74,7 @@ class HttpPusher(Pusher): self.timed_call = None self._is_processing = False self._group_unread_count_by_room = hs.config.push_group_unread_count_by_room + self._pusherpool = hs.get_pusherpool() self.data = pusher_config.data if self.data is None: @@ -299,7 +300,7 @@ class HttpPusher(Pusher): ) else: logger.info("Pushkey %s was rejected: removing", pk) - await self.hs.remove_pusher(self.app_id, pk, self.user_id) + await self._pusherpool.remove_pusher(self.app_id, pk, self.user_id) return True async def _build_notification_dict( |