diff options
| author | Erik Johnston <erik@matrix.org> | 2020-01-27 13:47:50 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2020-01-27 13:47:50 +0000 |
| commit | d5275fc55f4edc42d1543825da2c13df63d96927 (patch) | |
| tree | 2244270ee23c522bab16e28e7c3fac94aed78eab /synapse/replication/tcp/protocol.py | |
| parent | Merge pull request #6775 from matrix-org/jaywink/worker-docs-tweaks (diff) | |
| download | synapse-d5275fc55f4edc42d1543825da2c13df63d96927.tar.xz | |
Propagate cache invalidates from workers to other workers. (#6748)
Currently if a worker invalidates a cache it will be streamed to master, which then didn't forward those to other workers.
Diffstat (limited to 'synapse/replication/tcp/protocol.py')
| -rw-r--r-- | synapse/replication/tcp/protocol.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py index 131e5acb09..bc1482a9bb 100644 --- a/synapse/replication/tcp/protocol.py +++ b/synapse/replication/tcp/protocol.py @@ -459,7 +459,7 @@ class ServerReplicationStreamProtocol(BaseReplicationStreamProtocol): await self.streamer.on_remove_pusher(cmd.app_id, cmd.push_key, cmd.user_id) async def on_INVALIDATE_CACHE(self, cmd): - self.streamer.on_invalidate_cache(cmd.cache_func, cmd.keys) + await self.streamer.on_invalidate_cache(cmd.cache_func, cmd.keys) async def on_REMOTE_SERVER_UP(self, cmd: RemoteServerUpCommand): self.streamer.on_remote_server_up(cmd.data) |