We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 30edfde commit b9cd9c2Copy full SHA for b9cd9c2
test/test_client.py
@@ -2036,6 +2036,7 @@ def timeout_task():
2036
2037
class TestClientPool(MockClientTest):
2038
2039
+ @client_context.require_connection
2040
def test_rs_client_does_not_maintain_pool_to_arbiters(self):
2041
listener = CMAPListener()
2042
c = MockClient(
@@ -2065,6 +2066,7 @@ def test_rs_client_does_not_maintain_pool_to_arbiters(self):
2065
2066
arbiter = c._topology.get_server_by_address(('d', 4))
2067
self.assertFalse(arbiter.pool.sockets)
2068
2069
2070
def test_direct_client_maintains_pool_to_arbiter(self):
2071
2072
0 commit comments