diff options
| author | Richard van der Hoff <richard@matrix.org> | 2020-04-23 15:31:25 +0100 |
|---|---|---|
| committer | Richard van der Hoff <richard@matrix.org> | 2020-04-23 15:44:35 +0100 |
| commit | 23b28266acf0ff58eb290a0b86141d50a4fedba4 (patch) | |
| tree | 30e15a43c7ddef03ee753aa595a7822c28faacb1 /synapse/replication/tcp/streams | |
| parent | Revert "Revert "Merge pull request #7315 from matrix-org/babolivier/request_t... (diff) | |
| download | synapse-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.py | 5 |
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"] |