1 files changed, 1 insertions, 1 deletions
diff --git a/tests/replication/tcp/streams/_base.py b/tests/replication/tcp/streams/_base.py
index b7a61e22f2..f69564cd32 100644
--- a/tests/replication/tcp/streams/_base.py
+++ b/tests/replication/tcp/streams/_base.py
@@ -71,7 +71,7 @@ class BaseStreamTestCase(unittest.HomeserverTestCase):
 
     def replicate_stream(self, stream, token="NOW"):
         """Make the client end a REPLICATE command to set up a subscription to a stream"""
-        self.client.send_command(ReplicateCommand(stream, token))
+        self.client.send_command(ReplicateCommand(stream))
 
 
 class TestReplicationClientHandler(object):