Relax intermittent failing test_profile_server
@@ -5693,7 +5693,9 @@ async def test_futures_of_sorted(c, s, a, b):
@gen_cluster(client=True, worker_kwargs={"profile_cycle_interval": "10ms"})
async def test_profile_server(c, s, a, b):
- x = c.map(slowinc, range(10), delay=0.01, workers=a.address)
+ for i in range(5):
+ try:
+ x = c.map(slowinc, range(10), delay=0.01, workers=a.address, pure=False)
await wait(x)
await asyncio.gather(
@@ -5705,6 +5707,13 @@ async def test_profile_server(c, s, a, b):
p = await c.profile(scheduler=True) # Scheduler
assert "slowdec" in str(p)
+ except AssertionError:
+ if i == 4:
+ raise
+ else:
+ pass
+ else:
+ break
@gen_cluster(client=True)
