diff --git a/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_aspects.py b/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_aspects.py index 2d6796309728a4..e88891a4efe6e9 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_aspects.py +++ b/metadata-ingestion/src/datahub/ingestion/source/dremio/dremio_aspects.py @@ -296,6 +296,15 @@ def populate_dataset_mcp( ) yield mcp.as_workunit() + # View Definition + if dataset.dataset_type == DremioDatasetType.VIEW: + view_definition = self._create_view_properties(dataset) + mcp = MetadataChangeProposalWrapper( + entityUrn=dataset_urn, + aspect=view_definition, + ) + yield mcp.as_workunit() + # Glossary Terms if dataset.glossary_terms: glossary_terms = self._create_glossary_terms(dataset)