diff --git a/metadata-ingestion/src/datahub/ingestion/source/unity/source.py b/metadata-ingestion/src/datahub/ingestion/source/unity/source.py index 29562eaf3c..f4ef31078f 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/unity/source.py +++ b/metadata-ingestion/src/datahub/ingestion/source/unity/source.py @@ -464,7 +464,17 @@ class UnityCatalogSource(StatefulIngestionSourceBase, TestableSource): with self.report.new_stage(f"Ingest schema {schema.id}"): yield from self.gen_schema_containers(schema) - yield from self.process_tables(schema) + try: + yield from self.process_tables(schema) + except Exception as e: + logger.exception(f"Error parsing schema {schema}") + self.report.report_warning( + message="Missed schema because of parsing issues", + context=str(schema), + title="Error parsing schema", + exc=e, + ) + continue self.report.schemas.processed(schema.id)