diff options
| author | Erik Johnston <erik@matrix.org> | 2020-05-07 13:51:08 +0100 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-05-07 13:51:08 +0100 |
| commit | d7983b63a6746d92225295f1e9d521f847cf8ba7 (patch) | |
| tree | 13d581210d94c26bd75036592996f6f53f7d4bb2 /synapse/replication/slave/storage/events.py | |
| parent | Merge pull request #7398 from Starbix/alpine-3.11 (diff) | |
| download | synapse-d7983b63a6746d92225295f1e9d521f847cf8ba7.tar.xz | |
Support any process writing to cache invalidation stream. (#7436)
Diffstat (limited to 'synapse/replication/slave/storage/events.py')
| -rw-r--r-- | synapse/replication/slave/storage/events.py | 6 |
1 files changed, 2 insertions, 4 deletions
diff --git a/synapse/replication/slave/storage/events.py b/synapse/replication/slave/storage/events.py index 15011259df..b313720a4b 100644 --- a/synapse/replication/slave/storage/events.py +++ b/synapse/replication/slave/storage/events.py @@ -93,7 +93,7 @@ class SlavedEventStore( def get_room_min_stream_ordering(self): return self._backfill_id_gen.get_current_token() - def process_replication_rows(self, stream_name, token, rows): + def process_replication_rows(self, stream_name, instance_name, token, rows): if stream_name == "events": self._stream_id_gen.advance(token) for row in rows: @@ -111,9 +111,7 @@ class SlavedEventStore( row.relates_to, backfilled=True, ) - return super(SlavedEventStore, self).process_replication_rows( - stream_name, token, rows - ) + return super().process_replication_rows(stream_name, instance_name, token, rows) def _process_event_stream_row(self, token, row): data = row.data |