fix: replaced cluster workspace URL with dynamic URL that changes wit…

…h hosting platform. (#38)
dask-contrib · May 15, 2024 · 6df6c46 · 6df6c46
1 parent 63008a0
commit 6df6c46
Showing 1 changed file with 2 additions and 1 deletion.
diff --git 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():