From bf8752235118e9edd099a8105f8ec7d473b49820 Mon Sep 17 00:00:00 2001 From: Ayush Shah Date: Thu, 12 Aug 2021 14:36:02 +0530 Subject: [PATCH] elastic search pipeline fix --- ingestion/src/metadata/ingestion/source/metadata_rest.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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: