yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-10-07 23:04:32 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR: Fix usage failure after cross lineage (#22926)

Browse Source 
(cherry picked from commit e74de5df81277bf9f0af94f128c60821d5ab23ca)
This commit is contained in:
Mayur Singal 2025-08-13 16:30:29 +05:30 committed by Ashish Gupta
parent 76808342f7
commit 288c655436
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -198,7 +198,7 @@ class MetadataUsageBulkSink(BulkSink):
try: try:
table_entities = get_table_entities_from_query( table_entities = get_table_entities_from_query(
metadata=self.metadata, metadata=self.metadata,
service_name=self.service_name, service_names=self.service_name,
database_name=table_usage.databaseName, database_name=table_usage.databaseName,
database_schema=table_usage.databaseSchema, database_schema=table_usage.databaseSchema,
table_name=table_usage.table, table_name=table_usage.table,
@ -359,7 +359,7 @@ class MetadataUsageBulkSink(BulkSink):
""" """
table_entities = get_table_entities_from_query( table_entities = get_table_entities_from_query(
metadata=self.metadata, metadata=self.metadata,
service_name=self.service_name, service_names=self.service_name,
database_name=database, database_name=database,
database_schema=database_schema, database_schema=database_schema,
table_name=table_column.table, table_name=table_column.table,

2
ingestion/src/metadata/ingestion/source/dashboard/microstrategy/metadata.py
View File

@ -228,7 +228,7 @@ class MicrostrategySource(DashboardServiceSource):
for table in lineage_parser.source_tables: for table in lineage_parser.source_tables:
table_entities = get_table_entities_from_query( table_entities = get_table_entities_from_query(
metadata=self.metadata, metadata=self.metadata,
service_name=prefix_db_service_name, service_names=prefix_db_service_name,
database_name="*", database_name="*",
database_schema="*", database_schema="*",
table_name=str(table), table_name=str(table),