|
41 | 41 | IntegrationTest, |
42 | 42 | db_user, |
43 | 43 | db_pwd) |
| 44 | +from test.utils import connected |
44 | 45 | from test.version import Version |
45 | 46 |
|
46 | 47 |
|
@@ -551,8 +552,8 @@ def test_mongos_connection(self): |
551 | 552 | None, [{}] |
552 | 553 | ): |
553 | 554 | # Create a client e.g. with read_preference=NEAREST |
554 | | - c = get_client(host, port, |
555 | | - read_preference=mode(tag_sets=tag_sets)) |
| 555 | + c = connected(get_client( |
| 556 | + host, port, read_preference=mode(tag_sets=tag_sets))) |
556 | 557 |
|
557 | 558 | self.assertEqual(is_mongos, c.is_mongos) |
558 | 559 | cursor = c.pymongo_test.test.find() |
@@ -591,8 +592,8 @@ def test_mongos_connection(self): |
591 | 592 | [{'dc': 'la'}, {'dc': 'sf'}], |
592 | 593 | [{'dc': 'la'}, {'dc': 'sf'}, {}], |
593 | 594 | ): |
594 | | - c = get_client(host, port, |
595 | | - read_preference=mode(tag_sets=tag_sets)) |
| 595 | + c = connected(get_client( |
| 596 | + host, port, read_preference=mode(tag_sets=tag_sets))) |
596 | 597 |
|
597 | 598 | self.assertEqual(is_mongos, c.is_mongos) |
598 | 599 | cursor = c.pymongo_test.test.find() |
|
0 commit comments