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),