diff options
| author | Richard van der Hoff <1389908+richvdh@users.noreply.github.com> | 2019-03-28 18:31:17 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2019-03-28 18:31:17 +0000 |
| commit | d688a51736796d88f1dd72930869bbbabefbeeb5 (patch) | |
| tree | 7b8a6a32d838132d3ed6e3fc87abffcd5a2b8756 /synapse/replication/tcp/protocol.py | |
| parent | remove log line for password (#4965) (diff) | |
| parent | Merge remote-tracking branch 'origin/develop' into rav/refactor_parse_row (diff) | |
| download | synapse-d688a51736796d88f1dd72930869bbbabefbeeb5.tar.xz | |
Merge pull request #4954 from matrix-org/rav/refactor_parse_row
Refactors to replication stream row update/parsing
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", |