diff options
| author | Patrick Cloke <clokep@users.noreply.github.com> | 2020-12-15 10:41:34 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-12-15 10:41:34 -0500 |
| commit | b3a4b53587108af7c58acc45a0441304689f3ac9 (patch) | |
| tree | 6819625f82aac67a79203c16fb52aa13cb72a469 /synapse/push/pusherpool.py | |
| parent | Fix startup failure with localdb_enabled: False (#8937) (diff) | |
| download | synapse-b3a4b53587108af7c58acc45a0441304689f3ac9.tar.xz | |
Fix handling of stream tokens for push. (#8943)
Removes faulty assertions and fixes the logic to ensure the max stream token is always set.
Diffstat (limited to 'synapse/push/pusherpool.py')
| -rw-r--r-- | synapse/push/pusherpool.py | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/synapse/push/pusherpool.py b/synapse/push/pusherpool.py index 9fcc0b8a64..9c12d81cfb 100644 --- a/synapse/push/pusherpool.py +++ b/synapse/push/pusherpool.py @@ -129,9 +129,8 @@ class PusherPool: ) # create the pusher setting last_stream_ordering to the current maximum - # stream ordering in event_push_actions, so it will process - # pushes from this point onwards. - last_stream_ordering = await self.store.get_latest_push_action_stream_ordering() + # stream ordering, so it will process pushes from this point onwards. + last_stream_ordering = self.store.get_room_max_stream_ordering() await self.store.add_pusher( user_id=user_id, |