mirror of
https://github.com/open-metadata/OpenMetadata.git
synced 2025-12-28 07:58:31 +00:00
allow powerbi datamodel children in col.lineage (#18030)
This commit is contained in:
parent
8dc6b7d282
commit
9442cac1a5
@ -544,12 +544,12 @@ class PowerbiSource(DashboardServiceSource):
|
||||
to_entity=report_entity, from_entity=datamodel_entity
|
||||
)
|
||||
|
||||
# create the lineage between table and datamodel
|
||||
yield from self.create_table_datamodel_lineage(
|
||||
db_service_name=db_service_name,
|
||||
tables=dataset.tables,
|
||||
datamodel_entity=datamodel_entity,
|
||||
)
|
||||
for table in dataset.tables or []:
|
||||
yield self._get_table_and_datamodel_lineage(
|
||||
db_service_name=db_service_name,
|
||||
table=table,
|
||||
datamodel_entity=datamodel_entity,
|
||||
)
|
||||
|
||||
# create the lineage between table and datamodel using the pbit files
|
||||
if self.client.file_client:
|
||||
@ -678,20 +678,6 @@ class PowerbiSource(DashboardServiceSource):
|
||||
)
|
||||
)
|
||||
|
||||
def create_table_datamodel_lineage(
|
||||
self,
|
||||
db_service_name: str,
|
||||
tables: Optional[List[PowerBiTable]],
|
||||
datamodel_entity: Optional[DashboardDataModel],
|
||||
) -> Iterable[Either[CreateDashboardRequest]]:
|
||||
"""Method to create lineage between table and datamodels"""
|
||||
for table in tables or []:
|
||||
yield self._get_table_and_datamodel_lineage(
|
||||
db_service_name=db_service_name,
|
||||
table=table,
|
||||
datamodel_entity=datamodel_entity,
|
||||
)
|
||||
|
||||
def yield_dashboard_lineage_details(
|
||||
self,
|
||||
dashboard_details: Union[PowerBIDashboard, PowerBIReport],
|
||||
|
||||
@ -30,6 +30,7 @@ export const DATATYPES_HAVING_SUBFIELDS = [
|
||||
'STRUCT',
|
||||
'ARRAY',
|
||||
'UNION',
|
||||
'TABLE',
|
||||
];
|
||||
|
||||
export const PIPELINE_EDGE_WIDTH = 200;
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user