diff --git a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_lineage.py b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_lineage.py index 813dae726b1591..933431b014e394 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_lineage.py +++ b/metadata-ingestion/src/datahub/ingestion/source/snowflake/snowflake_lineage.py @@ -392,9 +392,8 @@ def _populate_lineage(self, conn: SnowflakeConnection) -> None: upstream_table_name = self.get_dataset_identifier_from_qualified_name( db_row["UPSTREAM_TABLE_NAME"] ) - if not ( - self._is_dataset_pattern_allowed(key, "table") - or self._is_dataset_pattern_allowed(upstream_table_name, "table") + if not self._is_dataset_pattern_allowed(key, "table") or not ( + self._is_dataset_pattern_allowed(upstream_table_name, "table") ): continue