summary refs log tree commit diff
path: root/synapse/push/httppusher.py
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2021-04-23 14:38:31 +0100
committerAndrew Morgan <andrew@amorgan.xyz>2021-04-23 14:38:31 +0100
commit6afa265e4e3aac05491c78c1720710a909748a23 (patch)
tree905ec9a7bc3169eb11bdd74092fee5b9cf1da847 /synapse/push/httppusher.py
parentMerge commit '1b2d6d55c' into anoa/dinsic_release_1_31_0 (diff)
parentClean up `ShardedWorkerHandlingConfig` (#9466) (diff)
downloadsynapse-6afa265e4e3aac05491c78c1720710a909748a23.tar.xz
Merge commit '292792194' into anoa/dinsic_release_1_31_0
Diffstat (limited to 'synapse/push/httppusher.py')
-rw-r--r--synapse/push/httppusher.py3
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(