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/storage | |
| 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/storage')
| -rw-r--r-- | synapse/storage/databases/main/event_push_actions.py | 10 |
1 files changed, 0 insertions, 10 deletions
diff --git a/synapse/storage/databases/main/event_push_actions.py b/synapse/storage/databases/main/event_push_actions.py index 2e56dfaf31..e5c03cc609 100644 --- a/synapse/storage/databases/main/event_push_actions.py +++ b/synapse/storage/databases/main/event_push_actions.py @@ -894,16 +894,6 @@ class EventPushActionsStore(EventPushActionsWorkerStore): pa["actions"] = _deserialize_action(pa["actions"], pa["highlight"]) return push_actions - async def get_latest_push_action_stream_ordering(self): - def f(txn): - txn.execute("SELECT MAX(stream_ordering) FROM event_push_actions") - return txn.fetchone() - - result = await self.db_pool.runInteraction( - "get_latest_push_action_stream_ordering", f - ) - return result[0] or 0 - def _remove_old_push_actions_before_txn( self, txn, room_id, user_id, stream_ordering ): |