yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-01 05:03:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use Table FQN instead of Name for usage status (#6952)

Browse Source 
* Use Table FQN instead of Name for status

* Update log with fqn instead of name
This commit is contained in:
Mayur Singal 2022-08-26 12:28:30 +05:30 committed by GitHub
parent bdbbca0efe
commit 6c1f84dcd7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ingestion/src/metadata/ingestion/bulksink/metadata_usage.py
View File

@ -117,11 +117,13 @@ class MetadataUsageBulkSink(BulkSink):
) )
logger.info( logger.info(
"Successfully table usage published for {}".format( "Successfully table usage published for {}".format(
value_dict["table_entity"].name.__root__ value_dict["table_entity"].fullyQualifiedName.__root__
) )
) )
self.status.records_written( self.status.records_written(
"Table: {}".format(value_dict["table_entity"].name.__root__) "Table: {}".format(
value_dict["table_entity"].fullyQualifiedName.__root__
)
) )
except ValidationError as err: except ValidationError as err:
logger.error( logger.error(
@ -131,11 +133,13 @@ class MetadataUsageBulkSink(BulkSink):
self.status.failures.append(table_usage_request) self.status.failures.append(table_usage_request)
logger.error( logger.error(
"Failed to update usage for {} {}".format( "Failed to update usage for {} {}".format(
value_dict["table_entity"].name.__root__, err value_dict["table_entity"].fullyQualifiedName.__root__, err
) )
) )
self.status.failures.append( self.status.failures.append(
"Table: {}".format(value_dict["table_entity"].name.__root__) "Table: {}".format(
value_dict["table_entity"].fullyQualifiedName.__root__
)
) )
def iterate_files(self): def iterate_files(self):