diff --git a/dask_databricks/databrickscluster.py b/dask_databricks/databrickscluster.py index 96be4f8..3b064b8 100644 --- a/dask_databricks/databrickscluster.py +++ b/dask_databricks/databrickscluster.py @@ -47,7 +47,8 @@ async def _start(self): def dashboard_link(self): cluster_id = spark.conf.get("spark.databricks.clusterUsageTags.clusterId") org_id = spark.conf.get("spark.databricks.clusterUsageTags.orgId") - return f"https://dbc-dp-{org_id}.cloud.databricks.com/driver-proxy/o/{org_id}/{cluster_id}/8087/status" + workspace_url = spark.conf.get("spark.databricks.workspaceUrl") + return f"https://{workspace_url}/driver-proxy/o/{org_id}/{cluster_id}/8087/status" def get_client():