summary refs log tree commit diff
path: root/synapse/replication/tcp/streams
diff options
context:
space:
mode:
authorRichard van der Hoff <richard@matrix.org>2020-04-23 15:31:25 +0100
committerRichard van der Hoff <richard@matrix.org>2020-04-23 15:44:35 +0100
commit23b28266acf0ff58eb290a0b86141d50a4fedba4 (patch)
tree30e15a43c7ddef03ee753aa595a7822c28faacb1 /synapse/replication/tcp/streams
parentRevert "Revert "Merge pull request #7315 from matrix-org/babolivier/request_t... (diff)
downloadsynapse-23b28266acf0ff58eb290a0b86141d50a4fedba4.tar.xz
Remove 'limit' param from `get_repl_stream_updates` API
there doesn't seem to be much point in passing this limit all around, since
both sides agree it's meant to be 100.
Diffstat (limited to 'synapse/replication/tcp/streams')
-rw-r--r--synapse/replication/tcp/streams/_base.py5
1 files changed, 1 insertions, 4 deletions
diff --git a/synapse/replication/tcp/streams/_base.py b/synapse/replication/tcp/streams/_base.py
index a860072ccf..112bfead56 100644
--- a/synapse/replication/tcp/streams/_base.py
+++ b/synapse/replication/tcp/streams/_base.py
@@ -193,10 +193,7 @@ def make_http_update_function(hs, stream_name: str) -> UpdateFunction:
         from_token: int, upto_token: int, limit: int
     ) -> StreamUpdateResult:
         result = await client(
-            stream_name=stream_name,
-            from_token=from_token,
-            upto_token=upto_token,
-            limit=limit,
+            stream_name=stream_name, from_token=from_token, upto_token=upto_token,
         )
         return result["updates"], result["upto_token"], result["limited"]