diff options
| author | Erik Johnston <erik@matrix.org> | 2020-08-19 13:41:51 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-08-19 13:41:51 +0100 |
| commit | c9c544cda5748ab106464a8f58031bd60d1aba7b (patch) | |
| tree | fb46ee38e628eae7c417a2c19c64c28b30e8eb29 /synapse/replication/tcp | |
| parent | Switch the JSON byte producer from a pull to a push producer. (#8116) (diff) | |
| download | synapse-c9c544cda5748ab106464a8f58031bd60d1aba7b.tar.xz | |
Remove `ChainedIdGenerator`. (#8123)
It's just a thin wrapper around two ID gens to make `get_current_token` and `get_next` return tuples. This can easily be replaced by calling the appropriate methods on the underlying ID gens directly.
Diffstat (limited to 'synapse/replication/tcp')
| -rw-r--r-- | synapse/replication/tcp/streams/_base.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py index 1e92d52165..8c3caf30c9 100644 --- a/synapse/replication/tcp/streams/_base.py +++ b/synapse/replication/tcp/streams/_base.py @@ -352,7 +352,7 @@ class PushRulesStream(Stream): ) def _current_token(self, instance_name: str) -> int: - push_rules_token, _ = self.store.get_push_rules_stream_token() + push_rules_token = self.store.get_max_push_rules_stream_id() return push_rules_token |