File tree Expand file tree Collapse file tree 2 files changed +8
-8
lines changed Expand file tree Collapse file tree 2 files changed +8
-8
lines changed Original file line number Diff line number Diff line change @@ -1808,10 +1808,10 @@ async def fail_connect(*args, **kwargs):
1808
1808
1809
1809
await pool .reset_without_pause ()
1810
1810
1811
- await async_wait_until (lambda : len ( cm . records ) > 0 , "start creating connections" )
1812
- log_output = "" .join (cm .output )
1813
- self . assertIn ( "failed to connect" , log_output )
1814
- self .assertIn ("MongoClient background task encountered an error" , log_output )
1811
+ await async_wait_until (
1812
+ lambda : "failed to connect" in "" .join (cm .output ), "start creating connections"
1813
+ )
1814
+ self .assertIn ("MongoClient background task encountered an error" , "" . join ( cm . output ) )
1815
1815
1816
1816
@async_client_context .require_replica_set
1817
1817
async def test_direct_connection (self ):
Original file line number Diff line number Diff line change @@ -1765,10 +1765,10 @@ def fail_connect(*args, **kwargs):
1765
1765
1766
1766
pool .reset_without_pause ()
1767
1767
1768
- wait_until (lambda : len ( cm . records ) > 0 , "start creating connections" )
1769
- log_output = "" .join (cm .output )
1770
- self . assertIn ( "failed to connect" , log_output )
1771
- self .assertIn ("MongoClient background task encountered an error" , log_output )
1768
+ wait_until (
1769
+ lambda : "failed to connect" in "" .join (cm .output ), "start creating connections"
1770
+ )
1771
+ self .assertIn ("MongoClient background task encountered an error" , "" . join ( cm . output ) )
1772
1772
1773
1773
@client_context .require_replica_set
1774
1774
def test_direct_connection (self ):
You can’t perform that action at this time.
0 commit comments