Sparkjob - show and save UI ingress URL (#471)

mlrun · Oct 11, 2020 · 94a094c · 94a094c
1 parent 65a00a9
commit 94a094c
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/mlrun/runtimes/sparkjob.py b/mlrun/runtimes/sparkjob.py
@@ -232,7 +232,14 @@ def _run(self, runobj: RunObject, execution: MLClientCtx):
                             meta.name, driver, status
                         )
                     )
-                    logger.info("use .watch({}) to see logs".format(meta.name))
+                    resp = self.get_job(meta.name, meta.namespace)
+                    ui_ingress = (
+                        resp.get("status", {})
+                        .get("driverInfo", {})
+                        .get("webUIIngressAddress")
+                    )
+                    if ui_ingress:
+                        runobj.status.status_text = f"UI is available while the job is running: http://{ui_ingress}"
             else:
                 logger.error(
                     "SparkJob status unknown or failed, check pods: {}".format(