summary refs log tree commit diff
path: root/synapse/replication/resource.py
diff options
context:
space:
mode:
authorMark Haines <mjark@negativecurvature.net>2016-04-27 15:54:48 +0100
committerMark Haines <mjark@negativecurvature.net>2016-04-27 15:54:48 +0100
commit21d188bf95b6a75437f33f1dca1dd0a75dae86b4 (patch)
treed5f1e30fa3c6c32084d5d65f6b6fa5055cd818ec /synapse/replication/resource.py
parentMerge pull request #754 from matrix-org/markjh/check_for_nop (diff)
parentFix backfill replication to advance the stream correctly (diff)
downloadsynapse-21d188bf95b6a75437f33f1dca1dd0a75dae86b4.tar.xz
Merge pull request #755 from matrix-org/markjh/right_direction
Fix backfill replication to advance the stream correctly
Diffstat (limited to 'synapse/replication/resource.py')
-rw-r--r--synapse/replication/resource.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/synapse/replication/resource.py b/synapse/replication/resource.py
index e5c9a53929..149fc4c650 100644
--- a/synapse/replication/resource.py
+++ b/synapse/replication/resource.py
@@ -382,7 +382,7 @@ class _Writer(object):
             position = rows[-1][0]
 
         self.streams[name] = {
-            "position": str(position),
+            "position": position if type(position) is int else str(position),
             "field_names": fields,
             "rows": rows,
         }