From b32bb82bee5cbb57771db8afca5f02fe2bad9888 Mon Sep 17 00:00:00 2001 From: Patrick Cloke Date: Fri, 11 Mar 2022 07:27:24 -0500 Subject: temp --- tests/replication/slave/storage/test_events.py | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) (limited to 'tests') diff --git a/tests/replication/slave/storage/test_events.py b/tests/replication/slave/storage/test_events.py index 17dc42fd37..4e9ac3727a 100644 --- a/tests/replication/slave/storage/test_events.py +++ b/tests/replication/slave/storage/test_events.py @@ -250,10 +250,13 @@ class SlavedEventStoreTestCase(BaseSlavedStoreTestCase): self.replicate() self.check("get_rooms_for_user_with_stream_ordering", (USER_ID_2,), set()) - # limit the replication rate - repl_transport = self._server_transport - assert isinstance(repl_transport, FakeTransport) - repl_transport.autoflush = False + # limit the replication rate from server -> client. + print(len(self._redis_transports)) + print(self._redis_transports) + assert len(self._redis_transports) == 1 + for _, repl_transport in self._redis_transports: + assert isinstance(repl_transport, FakeTransport) + repl_transport.autoflush = False # build the join and message events and persist them in the same batch. logger.info("----- build test events ------") -- cgit 1.5.1