diff --git a/dask_kubernetes/classic/tests/test_async.py b/dask_kubernetes/classic/tests/test_async.py index 33fb70219..5bcc486c2 100644 --- a/dask_kubernetes/classic/tests/test_async.py +++ b/dask_kubernetes/classic/tests/test_async.py @@ -142,7 +142,7 @@ async def test_diagnostics_link_env_variable(k8s_cluster, pod_spec, user_env): pytest.importorskip("bokeh") with dask.config.set({"distributed.dashboard.link": "foo-{USER}-{port}"}): async with KubeCluster(pod_spec, asynchronous=True) as cluster: - port = cluster.scheduler_info["services"]["dashboard"] + port = cluster.forwarded_dashboard_port assert ( "foo-" + getpass.getuser() + "-" + str(port) in cluster.dashboard_link