diff options
| author | Richard van der Hoff <richard@matrix.org> | 2019-03-27 07:40:32 +0000 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2019-03-27 21:32:33 +0000 |
| commit | f570916a3eb4088500e966182dea82647a5acac2 (patch) | |
| tree | 3e0aafef86b16b813e1617d5352ba85085b422ec /synapse/replication/tcp/protocol.py | |
| parent | changelog (diff) | |
| download | synapse-f570916a3eb4088500e966182dea82647a5acac2.tar.xz | |
Add parse_row method to replication stream class
This will allow individual stream classes to override how a row is parsed.
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 02e5bf6cc8..9daec2c995 100644 --- a/synapse/replication/tcp/protocol.py +++ b/synapse/replication/tcp/protocol.py @@ -605,7 +605,7 @@ class ClientReplicationStreamProtocol(BaseReplicationStreamProtocol): inbound_rdata_count.labels(stream_name).inc() try: - row = STREAMS_MAP[stream_name].ROW_TYPE(*cmd.row) + row = STREAMS_MAP[stream_name].parse_row(cmd.row) except Exception: logger.exception( "[%s] Failed to parse RDATA: %r %r", |