Compare commits
1 commit
fix/footno
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
d2af1a2e62 |
1 changed files with 9 additions and 2 deletions
|
|
@ -1054,16 +1054,23 @@ async def test_breaker_isolates_sources(client, jobs, sync):
|
||||||
for _ in range(10):
|
for _ in range(10):
|
||||||
pool._breaker_for("bad").record_failure()
|
pool._breaker_for("bad").record_failure()
|
||||||
|
|
||||||
|
async def _good_jobs_drained():
|
||||||
|
while True:
|
||||||
|
done = await jobs.list_jobs(status=JobStatus.SUCCEEDED, limit=50)
|
||||||
|
if len(done) == 3:
|
||||||
|
return done
|
||||||
|
await asyncio.sleep(0.02)
|
||||||
|
|
||||||
await pool.start()
|
await pool.start()
|
||||||
try:
|
try:
|
||||||
await asyncio.sleep(0.2)
|
succeeded = await asyncio.wait_for(_good_jobs_drained(), timeout=5.0)
|
||||||
succeeded = await jobs.list_jobs(status=JobStatus.SUCCEEDED, limit=50)
|
|
||||||
queued = await jobs.list_jobs(status=JobStatus.QUEUED, limit=50)
|
queued = await jobs.list_jobs(status=JobStatus.QUEUED, limit=50)
|
||||||
finally:
|
finally:
|
||||||
await pool.stop()
|
await pool.stop()
|
||||||
|
|
||||||
assert {j.uri for j in succeeded} == {"g0", "g1", "g2"}
|
assert {j.uri for j in succeeded} == {"g0", "g1", "g2"}
|
||||||
assert {j.uri for j in queued} == {"b0", "b1", "b2"}
|
assert {j.uri for j in queued} == {"b0", "b1", "b2"}
|
||||||
|
assert [j.attempts for j in queued] == [0, 0, 0]
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.asyncio
|
@pytest.mark.asyncio
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue