diff --git a/metadata-ingestion/src/datahub/ingestion/source/tableau.py b/metadata-ingestion/src/datahub/ingestion/source/tableau.py index e6cc763892d277..6fb732d2260cd2 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/tableau.py +++ b/metadata-ingestion/src/datahub/ingestion/source/tableau.py @@ -247,9 +247,12 @@ def _create_upstream_table_lineage( for table in datasource.get("upstreamTables", []): # skip upstream tables when there is no column info when retrieving embedded datasource + # and when table name is None # Schema details for these will be taken care in self.emit_custom_sql_ds() if not is_custom_sql and not table.get("columns"): continue + elif table["name"] is None: + continue schema = self._get_schema(table.get("schema", ""), upstream_db) table_urn = make_table_urn(