diff --git a/metadata-ingestion/src/gometa/ingestion/extractor/generic.py b/metadata-ingestion/src/gometa/ingestion/extractor/generic.py index caf68e48a4..ac31aec9bf 100644 --- a/metadata-ingestion/src/gometa/ingestion/extractor/generic.py +++ b/metadata-ingestion/src/gometa/ingestion/extractor/generic.py @@ -11,6 +11,8 @@ class WorkUnitMCEExtractor(Extractor): pass def get_records(self, workunit) -> Iterable[RecordEnvelope[MetadataChangeEvent]]: + if len(workunit.mce.proposedSnapshot.aspects) == 0: + raise AttributeError('every mce must have at least one aspect') yield RecordEnvelope(workunit.mce, {}) def close(self):