diff --git a/ingestion/src/metadata/ingestion/source/metadata_rest.py b/ingestion/src/metadata/ingestion/source/metadata_rest.py index 7da50419e0d..74f0953c5be 100644 --- a/ingestion/src/metadata/ingestion/source/metadata_rest.py +++ b/ingestion/src/metadata/ingestion/source/metadata_rest.py @@ -55,7 +55,7 @@ class MetadataTablesRestSource(Source): def next_record(self) -> Iterable[TableEntity]: for table in self.tables: - self.status.records_produced(table.name) + self.status.scanned(table.name) yield table def get_status(self) -> SourceStatus: