File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -1964,6 +1964,7 @@ def timeout_task():
19641964
19651965class TestClientPool (MockClientTest ):
19661966
1967+ @client_context .require_connection
19671968 def test_rs_client_does_not_maintain_pool_to_arbiters (self ):
19681969 listener = CMAPListener ()
19691970 c = MockClient (
@@ -1993,6 +1994,7 @@ def test_rs_client_does_not_maintain_pool_to_arbiters(self):
19931994 arbiter = c ._topology .get_server_by_address (('d' , 4 ))
19941995 self .assertFalse (arbiter .pool .sockets )
19951996
1997+ @client_context .require_connection
19961998 def test_direct_client_maintains_pool_to_arbiter (self ):
19971999 listener = CMAPListener ()
19982000 c = MockClient (
@@ -2007,7 +2009,6 @@ def test_direct_client_maintains_pool_to_arbiter(self):
20072009 )
20082010 self .addCleanup (c .close )
20092011
2010- print (c .topology_description )
20112012 wait_until (lambda : len (c .nodes ) == 1 , 'connect' )
20122013 self .assertEqual (c .address , ('c' , 3 ))
20132014 # Assert that we create 1 pooled connection.
You can’t perform that action at this time.
0 commit comments