From dfdb070f91116ab4c81791035704ba4615ccfaab Mon Sep 17 00:00:00 2001 From: Gabe Joseph Date: Thu, 9 Jun 2022 10:19:45 -0600 Subject: [PATCH] Revert "Fix CLI Scheduler Tests (#6502)" This reverts commit 781af78049cbd46129adbb596974f68c2e555fcb. --- distributed/cli/tests/test_dask_scheduler.py | 16 ++++++---------- 1 file changed, 6 insertions(+), 10 deletions(-) diff --git a/distributed/cli/tests/test_dask_scheduler.py b/distributed/cli/tests/test_dask_scheduler.py index 2e992a64143..308ee86a011 100644 --- a/distributed/cli/tests/test_dask_scheduler.py +++ b/distributed/cli/tests/test_dask_scheduler.py @@ -99,24 +99,22 @@ def test_dashboard_non_standard_ports(loop): pytest.importorskip("bokeh") with popen( - ["dask-scheduler", "--port", "23448", "--dashboard-address", ":24832"], - flush_output=False, + ["dask-scheduler", "--port", "3448", "--dashboard-address", ":4832"] ) as proc: - line = wait_for_log_line(b"dashboard at", proc.stdout) - with Client("127.0.0.1:23448", loop=loop) as c: + with Client("127.0.0.1:3448", loop=loop) as c: pass start = time() while True: try: - response = requests.get("http://localhost:24832/status/") + response = requests.get("http://localhost:4832/status/") assert response.ok break except Exception: sleep(0.1) assert time() < start + 20 with pytest.raises(Exception): - requests.get("http://localhost:24832/status/") + requests.get("http://localhost:4832/status/") @pytest.mark.skipif(not LINUX, reason="Need 127.0.0.2 to mean localhost") @@ -209,10 +207,8 @@ def check_pidfile(proc, pidfile): def test_scheduler_port_zero(loop): with tmpfile() as fn: with popen( - ["dask-scheduler", "--no-dashboard", "--scheduler-file", fn, "--port", "0"], - flush_output=False, - ) as proc: - line = wait_for_log_line(b"dashboard at", proc.stdout) + ["dask-scheduler", "--no-dashboard", "--scheduler-file", fn, "--port", "0"] + ): with Client(scheduler_file=fn, loop=loop) as c: assert c.scheduler.port assert c.scheduler.port != 8786