diff --git a/ingestion/src/metadata/ingestion/source/dashboard/tableau/metadata.py b/ingestion/src/metadata/ingestion/source/dashboard/tableau/metadata.py index 39626bbfde13..42fe0f76be35 100644 --- a/ingestion/src/metadata/ingestion/source/dashboard/tableau/metadata.py +++ b/ingestion/src/metadata/ingestion/source/dashboard/tableau/metadata.py @@ -383,9 +383,12 @@ def _get_column_lineage( # pylint: disable=arguments-differ column=column.id, ) for to_column in to_columns: - column_lineage.append( - ColumnLineage(fromColumns=[from_column], toColumn=to_column) - ) + if from_column and to_column: + column_lineage.append( + ColumnLineage( + fromColumns=[from_column], toColumn=to_column + ) + ) return column_lineage except Exception as exc: logger.debug(f"Error to get column lineage: {exc}") @@ -452,6 +455,7 @@ def _get_table_datamodel_lineage( column.id for field in upstream_data_model.fields for column in field.upstreamColumns + if column is not None } for table in datamodel.upstreamTables or []: om_tables = self._get_database_tables(db_service_entity, table) @@ -889,6 +893,9 @@ def get_project_name(self, dashboard_details: Any) -> Optional[str]: try: return dashboard_details.project.name except Exception as exc: + logger.info( + f"Cannot parse project name for dashboard:{dashboard_details.id} from Tableau server" + ) logger.debug(traceback.format_exc()) logger.warning( f"Error fetching project name for {dashboard_details.id}: {exc}"