summary refs log tree commit diff
path: root/synapse/replication/tcp/protocol.py
diff options
context:
space:
mode:
authorAmber Brown <hawkowl@atleastfornow.net>2018-05-22 15:02:38 -0500
committerAmber Brown <hawkowl@atleastfornow.net>2018-05-22 15:02:38 -0500
commit228f1f584ef100f18440362303775f7c860c01ca (patch)
treedc1fedf30cbca7bed40d5f0945dea024988cfb1d /synapse/replication/tcp/protocol.py
parentupdate gitignore to remove some files that got put on my machine (diff)
downloadsynapse-228f1f584ef100f18440362303775f7c860c01ca.tar.xz
fix the test failures
Diffstat (limited to '')
-rw-r--r--synapse/replication/tcp/protocol.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/tcp/protocol.py b/synapse/replication/tcp/protocol.py
index 5848f57c5e..bdb110663c 100644
--- a/synapse/replication/tcp/protocol.py
+++ b/synapse/replication/tcp/protocol.py
@@ -513,7 +513,7 @@ class ClientReplicationStreamProtocol(BaseReplicationStreamProtocol):
 
     def on_RDATA(self, cmd):
         stream_name = cmd.stream_name
-        inbound_rdata_count.inc(stream_name)
+        inbound_rdata_count.labels(stream_name).inc()
 
         try:
             row = STREAMS_MAP[stream_name].ROW_TYPE(*cmd.row)