diff options
| author | Erik Johnston <erik@matrix.org> | 2020-09-29 21:48:33 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-09-29 21:48:33 +0100 |
| commit | ea70f1c362dc4bd6c0f8a67e16ed0971fe095e5b (patch) | |
| tree | 83a37ad1ffa3e1432dc4ca281a0cfec5ed600445 /synapse/handlers/pagination.py | |
| parent | Update description of server_name config option (#8415) (diff) | |
| download | synapse-ea70f1c362dc4bd6c0f8a67e16ed0971fe095e5b.tar.xz | |
Various clean ups to room stream tokens. (#8423)
Diffstat (limited to 'synapse/handlers/pagination.py')
| -rw-r--r-- | synapse/handlers/pagination.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/synapse/handlers/pagination.py b/synapse/handlers/pagination.py index a0b3bdb5e0..d6779a4b44 100644 --- a/synapse/handlers/pagination.py +++ b/synapse/handlers/pagination.py @@ -25,7 +25,7 @@ from synapse.logging.context import run_in_background from synapse.metrics.background_process_metrics import run_as_background_process from synapse.storage.state import StateFilter from synapse.streams.config import PaginationConfig -from synapse.types import Requester, RoomStreamToken +from synapse.types import Requester from synapse.util.async_helpers import ReadWriteLock from synapse.util.stringutils import random_string from synapse.visibility import filter_events_for_client @@ -373,10 +373,9 @@ class PaginationHandler: # case "JOIN" would have been returned. assert member_event_id - leave_token_str = await self.store.get_topological_token_for_event( + leave_token = await self.store.get_topological_token_for_event( member_event_id ) - leave_token = RoomStreamToken.parse(leave_token_str) assert leave_token.topological is not None if leave_token.topological < curr_topo: |