From 6cd6f6d9453b60a3d79c1ef58bb55364178f7141 Mon Sep 17 00:00:00 2001 From: TalkWithKeyboard <610347922@qq.com> Date: Sun, 15 May 2022 16:02:32 +0800 Subject: [PATCH] fix NPE while get relation --- dbt/adapters/spark/impl.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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]