diff --git a/dbt/adapters/spark/impl.py b/dbt/adapters/spark/impl.py index 7de5fceb9..9652a24be 100644 --- a/dbt/adapters/spark/impl.py +++ b/dbt/adapters/spark/impl.py @@ -213,7 +213,7 @@ def get_relation( cached = super().get_relation(database, schema, identifier) logger.info(f">>> get_relation: {cached.render() if cached is not None else 'Empty'}") - return self._set_relation_information(cached) + return self._set_relation_information(cached) if cached else None def parse_describe_extended( self, relation: Relation, raw_rows: List[agate.Row]