diff options
| author | Erik Johnston <erik@matrix.org> | 2022-06-06 11:24:12 +0300 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2022-06-06 09:24:12 +0100 |
| commit | e3163e2e11cf8bffa4cb3e58ac0b86a83eca314c (patch) | |
| tree | 639271e4b4d4157b95047f801f6b22bf39a24f08 /synapse/server_notices | |
| parent | Remove groups code from synapse_port_db. (#12899) (diff) | |
| download | synapse-e3163e2e11cf8bffa4cb3e58ac0b86a83eca314c.tar.xz | |
Reduce the amount of state we pull from the DB (#12811)
Diffstat (limited to 'synapse/server_notices')
| -rw-r--r-- | synapse/server_notices/resource_limits_server_notices.py | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/synapse/server_notices/resource_limits_server_notices.py b/synapse/server_notices/resource_limits_server_notices.py index b5f3a0c74e..6863020778 100644 --- a/synapse/server_notices/resource_limits_server_notices.py +++ b/synapse/server_notices/resource_limits_server_notices.py @@ -36,6 +36,7 @@ class ResourceLimitsServerNotices: def __init__(self, hs: "HomeServer"): self._server_notices_manager = hs.get_server_notices_manager() self._store = hs.get_datastores().main + self._storage_controllers = hs.get_storage_controllers() self._auth = hs.get_auth() self._config = hs.config self._resouce_limited = False @@ -178,8 +179,10 @@ class ResourceLimitsServerNotices: currently_blocked = False pinned_state_event = None try: - pinned_state_event = await self._state.get_current_state( - room_id, event_type=EventTypes.Pinned + pinned_state_event = ( + await self._storage_controllers.state.get_current_state_event( + room_id, event_type=EventTypes.Pinned, state_key="" + ) ) except AuthError: # The user has yet to join the server notices room |