From 288c65543610133e37305298a9835bbbe1a079fc Mon Sep 17 00:00:00 2001 From: Mayur Singal <39544459+ulixius9@users.noreply.github.com> Date: Wed, 13 Aug 2025 16:30:29 +0530 Subject: [PATCH] MINOR: Fix usage failure after cross lineage (#22926) (cherry picked from commit e74de5df81277bf9f0af94f128c60821d5ab23ca) --- ingestion/src/metadata/ingestion/bulksink/metadata_usage.py | 4 ++-- .../ingestion/source/dashboard/microstrategy/metadata.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py index 8b08176d97b..095a78e8785 100644 --- a/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py +++ b/ingestion/src/metadata/ingestion/bulksink/metadata_usage.py @@ -198,7 +198,7 @@ class MetadataUsageBulkSink(BulkSink): try: table_entities = get_table_entities_from_query( metadata=self.metadata, - service_name=self.service_name, + service_names=self.service_name, database_name=table_usage.databaseName, database_schema=table_usage.databaseSchema, table_name=table_usage.table, @@ -359,7 +359,7 @@ class MetadataUsageBulkSink(BulkSink): """ table_entities = get_table_entities_from_query( metadata=self.metadata, - service_name=self.service_name, + service_names=self.service_name, database_name=database, database_schema=database_schema, table_name=table_column.table, diff --git a/ingestion/src/metadata/ingestion/source/dashboard/microstrategy/metadata.py b/ingestion/src/metadata/ingestion/source/dashboard/microstrategy/metadata.py index 8af7f57ae1e..578fcada0f0 100644 --- a/ingestion/src/metadata/ingestion/source/dashboard/microstrategy/metadata.py +++ b/ingestion/src/metadata/ingestion/source/dashboard/microstrategy/metadata.py @@ -228,7 +228,7 @@ class MicrostrategySource(DashboardServiceSource): for table in lineage_parser.source_tables: table_entities = get_table_entities_from_query( metadata=self.metadata, - service_name=prefix_db_service_name, + service_names=prefix_db_service_name, database_name="*", database_schema="*", table_name=str(table),