Split DeployedWorkflows out of WorkflowsDeployment

src/databricks/labs/ucx/cli.py

@@ -44,7 +44,7 @@
 @ucx.command
 def workflows(w: WorkspaceClient):
     """Show deployed workflows and their state"""
-    installation = WorkflowsDeployment.current(w)
+    installation = WorkflowsDeployment.for_cli(w)
     logger.info("Fetching deployed jobs...")
     print(json.dumps(installation.latest_job_status()))
 
@@ -161,16 +161,17 @@ def validate_external_locations(w: WorkspaceClient, prompts: Prompts):
 @ucx.command
 def ensure_assessment_run(w: WorkspaceClient):
     """ensure the assessment job was run on a workspace"""
-    installation = WorkspaceInstallation.current(w)
-    installation.validate_and_run("assessment")
+    deployed_workflows = WorkflowsDeployment.for_cli(w)
+    if not deployed_workflows.validate_step("assessment"):
+        deployed_workflows.run_workflow("assessment")
 
 
 @ucx.command
 def repair_run(w: WorkspaceClient, step):
     """Repair Run the Failed Job"""
     if not step:
         raise KeyError("You did not specify --step")
-    installation = WorkflowsDeployment.current(w)
+    installation = WorkflowsDeployment.for_cli(w)
     logger.info(f"Repair Running {step} Job")
     installation.repair_run(step)
 

src/databricks/labs/ucx/install.py

@@ -518,10 +518,6 @@ def _remove_warehouse(self):
         except InvalidParameterValue:
             logger.error("Error accessing warehouse details")
 
-    def validate_and_run(self, step: str):
-        if not self._workflows_installer.validate_step(step):
-            self._workflows_installer.run_workflow(step)
-
     def _trigger_workflow(self, step: str):
         job_id = int(self._install_state.jobs[step])
         job_url = f"{self._ws.config.host}#job/{job_id}"

src/databricks/labs/ucx/installer/mixins.py

@@ -1,6 +1,5 @@
 import logging
 import os
-from datetime import datetime
 
 from databricks.labs.blueprint.installation import Installation
 from databricks.sdk import WorkspaceClient
@@ -31,23 +30,6 @@ def _my_username(self):
                 raise PermissionError(msg)
         return self._me.user_name
 
-    @staticmethod
-    def _readable_timedelta(epoch):
-        when = datetime.utcfromtimestamp(epoch)
-        duration = datetime.now() - when
-        data = {}
-        data["days"], remaining = divmod(duration.total_seconds(), 86_400)
-        data["hours"], remaining = divmod(remaining, 3_600)
-        data["minutes"], data["seconds"] = divmod(remaining, 60)
-
-        time_parts = ((name, round(value)) for (name, value) in data.items())
-        time_parts = [f"{value} {name[:-1] if value == 1 else name}" for name, value in time_parts if value > 0]
-        if len(time_parts) > 0:
-            time_parts.append("ago")
-        if time_parts:
-            return " ".join(time_parts)
-        return "less than 1 second ago"
-
     @property
     def _warehouse_id(self) -> str:
         if self._config.warehouse_id is not None: