summary refs log tree commit diff
path: root/synapse/storage/stream.py
diff options
context:
space:
mode:
authorErik Johnston <erik@matrix.org>2018-05-23 11:37:25 +0100
committerErik Johnston <erik@matrix.org>2018-05-25 10:56:42 +0100
commit516207a96671a82fdd4a285d9628bb5e79bf67f7 (patch)
treec0fe43dafc026fba947f974fe9652ba577c52d0b /synapse/storage/stream.py
parentFix backfill (diff)
downloadsynapse-516207a96671a82fdd4a285d9628bb5e79bf67f7.tar.xz
Fix non integer limit
Diffstat (limited to 'synapse/storage/stream.py')
-rw-r--r--synapse/storage/stream.py3
1 files changed, 2 insertions, 1 deletions
diff --git a/synapse/storage/stream.py b/synapse/storage/stream.py
index 65919ac7be..d048dd9579 100644
--- a/synapse/storage/stream.py
+++ b/synapse/storage/stream.py
@@ -757,7 +757,8 @@ class StreamWorkerStore(EventsWorkerStore, SQLBaseStore):
             bounds += " AND " + filter_clause
             args.extend(filter_args)
 
-        args.append(int(limit))
+        limit = int(limit)
+        args.append(limit)
 
         sql = (
             "SELECT event_id, chunk_id, topological_ordering, stream_ordering"