From cf734a67ddb3db90ea92f135f4b45d79ca86a27d Mon Sep 17 00:00:00 2001 From: Cor Zuurmond Date: Fri, 25 Oct 2024 16:26:28 +0200 Subject: [PATCH] Format --- src/databricks/labs/ucx/contexts/workflow_task.py | 1 - src/databricks/labs/ucx/progress/workflows.py | 4 +++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/src/databricks/labs/ucx/contexts/workflow_task.py b/src/databricks/labs/ucx/contexts/workflow_task.py index e60e646668..387a0858b9 100644 --- a/src/databricks/labs/ucx/contexts/workflow_task.py +++ b/src/databricks/labs/ucx/contexts/workflow_task.py @@ -3,7 +3,6 @@ from databricks.labs.blueprint.installation import Installation from databricks.labs.lsql.backends import RuntimeBackend, SqlBackend -from databricks.labs.ucx.hive_metastore.table_migration_status import TableMigrationStatus from databricks.sdk import WorkspaceClient, core from databricks.labs.ucx.__about__ import __version__ diff --git a/src/databricks/labs/ucx/progress/workflows.py b/src/databricks/labs/ucx/progress/workflows.py index 7ebb8af15b..060b2fdccf 100644 --- a/src/databricks/labs/ucx/progress/workflows.py +++ b/src/databricks/labs/ucx/progress/workflows.py @@ -51,7 +51,9 @@ def refresh_table_migration_status(self, ctx: RuntimeContext) -> None: """Scan the tables (and views) in the inventory and record whether each has been migrated or not.""" ctx.migration_status_refresher.snapshot(force_refresh=True) - @job_task(depends_on=[verify_prerequisites, crawl_tables, refresh_table_migration_status], job_cluster="table_migration") + @job_task( + depends_on=[verify_prerequisites, crawl_tables, refresh_table_migration_status], job_cluster="table_migration" + ) def update_tables_history_log(self, ctx: RuntimeContext) -> None: """Update the history log with the latest tables inventory snapshot.""" # The table migration cluster is not legacy-ACL enabled, so we can't crawl from here.