From 94a094c1db5bdd05797cae206d0f42d7eaea558a Mon Sep 17 00:00:00 2001 From: urihoenig Date: Sun, 11 Oct 2020 20:38:21 +0300 Subject: [PATCH] Sparkjob - show and save UI ingress URL (#471) --- mlrun/runtimes/sparkjob.py | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/mlrun/runtimes/sparkjob.py b/mlrun/runtimes/sparkjob.py index 42a4729d68a..d11bbeb0a71 100644 --- 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(