We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent af8be8c commit 1cb554eCopy full SHA for 1cb554e
1 file changed
tests/integration/_utils.py
@@ -200,9 +200,8 @@ async def drain() -> list[_HasIdT]:
200
collected.append(item)
201
return collected
202
203
- # Loop on attempt count rather than `poll_until_condition`'s wall-clock deadline: each drain performs
204
- # paginated HTTP calls, and charging that time against a deadline would shrink the number of retries
205
- # under load — exactly when the eventual-consistency tolerance is needed most.
+ # Loop on attempt count rather than a wall-clock deadline: drains take HTTP time, and charging it
+ # against a deadline would mean fewer retries under load — exactly when they are needed most.
206
collected = await drain()
207
for _ in range(max_attempts - 1):
208
if expected_ids.issubset(item.id for item in collected):
0 commit comments