diff options
| author | Olivier Wilkinson (reivilibre) <olivier@librepush.net> | 2019-08-27 14:34:20 +0100 |
|---|---|---|
| committer | Olivier Wilkinson (reivilibre) <olivier@librepush.net> | 2019-08-27 14:34:20 +0100 |
| commit | 44d3c2e80b03bf7168ef23f0a3f080013d8800b0 (patch) | |
| tree | 0a3dfc293d7cec8c2ab8a2f0a26e54df71e42fd5 | |
| parent | For user stats, handle other membership transitions properly. (diff) | |
| download | synapse-44d3c2e80b03bf7168ef23f0a3f080013d8800b0.tar.xz | |
Invalidate `get_earliest_token_for_stats` cache as required.
Signed-off-by: Olivier Wilkinson (reivilibre) <olivier@librepush.net>
| -rw-r--r-- | synapse/storage/stats.py | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/synapse/storage/stats.py b/synapse/storage/stats.py index f86e9bd269..d345b2cb32 100644 --- a/synapse/storage/stats.py +++ b/synapse/storage/stats.py @@ -433,6 +433,7 @@ class StatsStore(StateDeltasStore): elif complete_with_stream_id is not None: absolute_fields = absolute_fields.copy() absolute_fields["completed_delta_stream_id"] = complete_with_stream_id + self.get_earliest_token_for_stats.invalidate(stats_type, stats_id) # first upsert the `_current` table self._upsert_with_additive_relatives_txn( |