-
-
Notifications
You must be signed in to change notification settings - Fork 156
Closed
Labels
Description
Recently one test on the classic KubeCluster has started failing in CI.
=================================== FAILURES ===================================
______________________ test_diagnostics_link_env_variable ______________________
k8s_cluster = <pytest_kind.cluster.KindCluster object at 0x7f3d38ab58e0>
pod_spec = {'api_version': None,
'kind': None,
'metadata': {'annotations': {},
'cluster_name': None,
... 'value': 'worker'}],
'topology_spread_constraints': None,
'volumes': None},
'status': None}
user_env = None
@pytest.mark.asyncio
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"]
> assert str(port) in cluster.dashboard_link
E AssertionError: assert '8787' in 'foo-runner-52351'
E + where '8787' = str(8787)
E + and 'foo-runner-52351' = KubeCluster(dask-runner-04578db5-9, 'tcp://localhost:63965', workers=0, threads=0, memory=0 B).dashboard_link
dask_kubernetes/classic/tests/test_async.py:147: AssertionError
it seems like the port listed under the dashboard service doesn't match up with the port being formatted into the daskboard_link.
https://github.com/dask/dask-kubernetes/runs/7413643070?check_suite_focus=true
Explored a little in #535 but haven't found a solution yet.