yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2026-01-05 20:17:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix #9923: Fix usage for tables with same name (#9925)

Browse Source 
* Fix #9923: Fix usage for tables with same name

* Fix #9923: Fix usage for tables with same name

* Update ingestion/src/metadata/ingestion/bulksink/metadata_usage.py

Co-authored-by: Nahuel <nahuel@getcollate.io>
This commit is contained in:
Mayur Singal 2023-01-26 21:23:41 +05:30 committed by GitHub
parent 4650a453e1
commit 3f9364d8a4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -102,7 +102,7 @@ class MetadataUsageBulkSink(BulkSink):
self.table_usage_map[table_entity.id.__root__] = {
"table_entity": table_entity,
"usage_count": table_usage.count,
"sql_queries": table_usage.sqlQueries,
"sql_queries": list(table_usage.sqlQueries or []),
"usage_date": table_usage.date,
"database": table_usage.databaseName,
"database_schema": table_usage.databaseSchema,

8
ingestion/src/metadata/ingestion/lineage/sql_lineage.py
View File

@ -136,8 +136,8 @@ def get_table_entities_from_query(
table_entities = search_table_entities(
metadata=metadata,
service_name=service_name,
database=database_name,
database_schema=database_schema,
database=database_query,
database_schema=schema_query,
table=table,
)
@ -147,8 +147,8 @@ def get_table_entities_from_query(
table_entities = search_table_entities(
metadata=metadata,
service_name=service_name,
database=database_query,
database_schema=schema_query,
database=database_name,
database_schema=database_schema,
table=table,
)