summary refs log tree commit diff
path: root/synapse/storage
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2020-08-26 13:15:20 +0100
committerGitHub <noreply@github.com>2020-08-26 13:15:20 +0100
commite3c91a3c5593c52298a7c511737d3e0eec4135ae (patch)
tree761c945817e6a837dd99f2549228fa40f725ebe7 /synapse/storage
parentConvert simple_select_one and simple_select_one_onecol to async (#8162) (diff)
downloadsynapse-e3c91a3c5593c52298a7c511737d3e0eec4135ae.tar.xz
Make SlavedIdTracker.advance have same interface as MultiWriterIDGenerator (#8171)
Diffstat (limited to 'synapse/storage')
-rw-r--r--synapse/storage/databases/main/events_worker.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/synapse/storage/databases/main/events_worker.py b/synapse/storage/databases/main/events_worker.py
index d59d73938a..e6247d682d 100644
--- a/synapse/storage/databases/main/events_worker.py
+++ b/synapse/storage/databases/main/events_worker.py
@@ -113,9 +113,9 @@ class EventsWorkerStore(SQLBaseStore):
 
     def process_replication_rows(self, stream_name, instance_name, token, rows):
         if stream_name == EventsStream.NAME:
-            self._stream_id_gen.advance(token)
+            self._stream_id_gen.advance(instance_name, token)
         elif stream_name == BackfillStream.NAME:
-            self._backfill_id_gen.advance(-token)
+            self._backfill_id_gen.advance(instance_name, -token)
 
         super().process_replication_rows(stream_name, instance_name, token, rows)