diff options
| author | Erik Johnston <erik@matrix.org> | 2020-03-25 10:51:46 +0000 |
|---|---|---|
| committer | Erik Johnston <erik@matrix.org> | 2020-03-25 10:51:46 +0000 |
| commit | 5473f1806aebfb120391924d1339856f69fa5076 (patch) | |
| tree | 9e5fadbfcf7f6d63cab4425362ff366a83011d44 /synapse/replication/slave/storage/push_rule.py | |
| parent | Add instance name to command (diff) | |
| download | synapse-5473f1806aebfb120391924d1339856f69fa5076.tar.xz | |
Change stream_positions to include instance name
Diffstat (limited to 'synapse/replication/slave/storage/push_rule.py')
| -rw-r--r-- | synapse/replication/slave/storage/push_rule.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/synapse/replication/slave/storage/push_rule.py b/synapse/replication/slave/storage/push_rule.py index eebd5a1fb6..a2f1522e73 100644 --- a/synapse/replication/slave/storage/push_rule.py +++ b/synapse/replication/slave/storage/push_rule.py @@ -39,7 +39,9 @@ class SlavedPushRuleStore(SlavedEventStore, PushRulesWorkerStore): def stream_positions(self): result = super(SlavedPushRuleStore, self).stream_positions() - result["push_rules"] = self._push_rules_stream_id_gen.get_current_token() + result["push_rules"] = { + "master": self._push_rules_stream_id_gen.get_current_token() + } return result def process_replication_rows(self, stream_name, token, rows): |