summary refs log tree commit diff
path: root/synapse/push
diff options
context:
space:
mode:
authorAndrew Morgan <andrew@amorgan.xyz>2020-10-19 18:14:26 +0100
committerAndrew Morgan <andrew@amorgan.xyz>2020-10-19 18:14:26 +0100
commit8857135bc66ec5100c956088d76e755849e6a790 (patch)
tree8047083a88c0886ef22ffeeee8469359b9318ce5 /synapse/push
parentMerge commit '61d8ff0d4' into anoa/dinsic_release_1_21_x (diff)
parentConverts event_federation and registration databases to async/await (#8061) (diff)
downloadsynapse-8857135bc66ec5100c956088d76e755849e6a790.tar.xz
Merge commit 'a0acdfa9e' into anoa/dinsic_release_1_21_x
* commit 'a0acdfa9e':
  Converts event_federation and registration databases to async/await (#8061)
Diffstat (limited to 'synapse/push')
-rw-r--r--synapse/push/pusherpool.py16
1 files changed, 0 insertions, 16 deletions
diff --git a/synapse/push/pusherpool.py b/synapse/push/pusherpool.py

index 305fd00fc0..8ac29ff725 100644 --- a/synapse/push/pusherpool.py +++ b/synapse/push/pusherpool.py
@@ -192,14 +192,6 @@ class PusherPool: for u in users_affected: if u in self.pushers: - # Don't push if the user account has expired - if self._account_validity.enabled: - expired = await self.store.is_account_expired( - u, self.clock.time_msec() - ) - if expired: - continue - for p in self.pushers[u].values(): p.on_new_notifications(min_stream_id, max_stream_id) @@ -220,14 +212,6 @@ class PusherPool: for u in users_affected: if u in self.pushers: - # Don't push if the user account has expired - if self._account_validity.enabled: - expired = yield self.store.is_account_expired( - u, self.clock.time_msec() - ) - if expired: - continue - for p in self.pushers[u].values(): p.on_new_receipts(min_stream_id, max_stream_id)