Skip to content

Commit e52b1e9

Browse files
authored
Warn about errors instead to avoid job task failure (#3219)
## Changes Log warning instead of raising the error to ensure job task run success. ### Linked issues Resolves #3214
1 parent 84e5499 commit e52b1e9

File tree

1 file changed

+3
-2
lines changed
  • src/databricks/labs/ucx/source_code

1 file changed

+3
-2
lines changed

src/databricks/labs/ucx/source_code/jobs.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
from typing import TypeVar
1414
from urllib import parse
1515

16-
from databricks.labs.blueprint.parallel import ManyError, Threads
16+
from databricks.labs.blueprint.parallel import Threads
1717
from databricks.labs.blueprint.paths import DBFSPath
1818
from databricks.labs.lsql.backends import SqlBackend
1919
from databricks.sdk import WorkspaceClient
@@ -430,7 +430,8 @@ def refresh_report(self, sql_backend: SqlBackend, inventory_database: str) -> No
430430
self._directfs_crawler.dump_all(job_dfsas)
431431
self._used_tables_crawler.dump_all(job_tables)
432432
if len(errors) > 0:
433-
raise ManyError(errors)
433+
error_messages = "\n".join([str(error) for error in errors])
434+
logger.warning(f"Errors occurred during linting:\n{error_messages}")
434435

435436
def lint_job(self, job_id: int) -> tuple[list[JobProblem], list[DirectFsAccess], list[UsedTable]]:
436437
try:

0 commit comments

Comments
 (0)