Sparkjob: UI ingress URL print

mlrun · Oct 11, 2020 · 3cff87e · 3cff87e
1 parent bfe974a
commit 3cff87e
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/mlrun/runtimes/sparkjob.py b/mlrun/runtimes/sparkjob.py
@@ -232,7 +232,12 @@ 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 = get_in(resp, "status.driverInfo.webUIIngressAddress")
+                    if ui_ingress:
+                        runobj.status.status_text = "UI is available while the job is running: http://{}".format(
+                            ui_ingress
+                        )
             else:
                 logger.error(
                     "SparkJob status unknown or failed, check pods: {}".format(