From 6c1f84dcd71cbd9a9fd3a49bf7316a48ff355ed7 Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Fri, 26 Aug 2022 12:28:30 +0530 Subject: [PATCH] Use Table FQN instead of Name for usage status (#6952) * Use Table FQN instead of Name for status * Update log with fqn instead of name --- .../metadata/ingestion/bulksink/metadata_usage.py | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py index ad83f486d73..a37bb50f7e2 100644 --- a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py +++ b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py @@ -117,11 +117,13 @@ class MetadataUsageBulkSink(BulkSink): ) logger.info( "Successfully table usage published for {}".format( - value_dict["table_entity"].name.__root__ + value_dict["table_entity"].fullyQualifiedName.__root__ ) ) self.status.records_written( - "Table: {}".format(value_dict["table_entity"].name.__root__) + "Table: {}".format( + value_dict["table_entity"].fullyQualifiedName.__root__ + ) ) except ValidationError as err: logger.error( @@ -131,11 +133,13 @@ class MetadataUsageBulkSink(BulkSink): self.status.failures.append(table_usage_request) logger.error( "Failed to update usage for {} {}".format( - value_dict["table_entity"].name.__root__, err + value_dict["table_entity"].fullyQualifiedName.__root__, err ) ) self.status.failures.append( - "Table: {}".format(value_dict["table_entity"].name.__root__) + "Table: {}".format( + value_dict["table_entity"].fullyQualifiedName.__root__ + ) ) def iterate_files(self):