We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1bf985e commit 7172a78Copy full SHA for 7172a78
ipyparallel/tests/test_cluster.py
@@ -322,8 +322,12 @@ async def test_cluster_manager_notice_stop(Cluster):
322
c_copy = cm.clusters[key]
323
324
await c.stop_cluster()
325
- # give it a moment to notice
326
- time.sleep(5)
+
327
# refresh list, cleans out stopped clusters
328
- cm.load_clusters()
+ # can take some time to notice
+ tic = time.perf_counter()
329
+ deadline = time.perf_counter() + 30
330
+ while time.perf_counter() < deadline and key in cm.clusters:
331
+ time.sleep(0.2)
332
+ cm.load_clusters()
333
assert key not in cm.clusters
0 commit comments