Skip to content

Commit b37fb91

Browse files
authored
PYTHON-4704 Migrate test_bulk.py to async (mongodb#1827)
1 parent 4e74c82 commit b37fb91

File tree

5 files changed

+1207
-25
lines changed

5 files changed

+1207
-25
lines changed

test/__init__.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -569,7 +569,10 @@ def require_secondaries_count(self, count):
569569
def sec_count():
570570
return 0 if not self.client else len(self.client.secondaries)
571571

572-
return self._require(lambda: sec_count() >= count, "Not enough secondaries available")
572+
def check():
573+
return sec_count() >= count
574+
575+
return self._require(check, "Not enough secondaries available")
573576

574577
@property
575578
def supports_secondary_read_pref(self):

test/asynchronous/__init__.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -571,7 +571,10 @@ def require_secondaries_count(self, count):
571571
async def sec_count():
572572
return 0 if not self.client else len(await self.client.secondaries)
573573

574-
return self._require(lambda: sec_count() >= count, "Not enough secondaries available")
574+
async def check():
575+
return await sec_count() >= count
576+
577+
return self._require(check, "Not enough secondaries available")
575578

576579
@property
577580
async def supports_secondary_read_pref(self):

0 commit comments

Comments
 (0)