Skip to content

Commit

Permalink
update on_skip to adjust for node that do not have schema
Browse files Browse the repository at this point in the history
  • Loading branch information
ChenyuLInx committed Jun 12, 2024
1 parent e699f5d commit 9cb3e57
Show file tree
Hide file tree
Showing 2 changed files with 15 additions and 1 deletion.
2 changes: 1 addition & 1 deletion core/dbt/task/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -410,7 +410,7 @@ def _skip_caused_by_ephemeral_failure(self):
return self.skip_cause.node.is_ephemeral_model

def on_skip(self):
schema_name = self.node.schema
schema_name = getattr(self.node, "schema", "")
node_name = self.node.name

error_message = None
Expand Down
14 changes: 14 additions & 0 deletions tests/unit/task/test_build.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
from dbt.contracts.graph.nodes import SavedQuery
from dbt.task.build import SavedQueryRunner


def test_saved_query_runner_on_skip(saved_query: SavedQuery):
runner = SavedQueryRunner(
config=None,
adapter=None,
node=saved_query,
node_index=None,
num_nodes=None,
)
# on_skip would work
runner.on_skip()

0 comments on commit 9cb3e57

Please sign in to comment.