From 9e2db6a176c83f6b8f132f05eb2e16ae1f5bc0fd Mon Sep 17 00:00:00 2001 From: Cor Zuurmond Date: Wed, 3 Jul 2024 08:13:43 +0200 Subject: [PATCH] Log the right amount of lint problems --- src/databricks/labs/ucx/source_code/jobs.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/databricks/labs/ucx/source_code/jobs.py b/src/databricks/labs/ucx/source_code/jobs.py index 636d57e608..aa82e9557f 100644 --- a/src/databricks/labs/ucx/source_code/jobs.py +++ b/src/databricks/labs/ucx/source_code/jobs.py @@ -298,8 +298,8 @@ def refresh_report(self, sql_backend: SqlBackend, inventory_database: str): tasks.append(functools.partial(self.lint_job, job.job_id)) logger.info(f"Running {tasks} linting tasks in parallel...") job_problems, errors = Threads.gather('linting workflows', tasks) - logger.info(f"Saving {len(job_problems)} linting problems...") job_problems_flattened = list(itertools.chain(*job_problems)) + logger.info(f"Saving {len(job_problems_flattened)} linting problems...") sql_backend.save_table( f'{inventory_database}.workflow_problems', job_problems_flattened,