diff --git a/core/dbt/node_runners.py b/core/dbt/node_runners.py index 03e26cd4166..860b5fd29f2 100644 --- a/core/dbt/node_runners.py +++ b/core/dbt/node_runners.py @@ -480,11 +480,14 @@ def after_execute(self, result): class SnapshotRunner(ModelRunner): def describe_node(self): - return "snapshot {}".format(self.node.name) + return "snapshot {}".format(self.get_node_representation()) def print_result_line(self, result): - dbt.ui.printer.print_snapshot_result_line(result, self.node_index, - self.num_nodes) + dbt.ui.printer.print_snapshot_result_line( + result, + self.get_node_representation(), + self.node_index, + self.num_nodes) class SeedRunner(ModelRunner): diff --git a/core/dbt/ui/printer.py b/core/dbt/ui/printer.py index 6f63618d1bc..d8b53347716 100644 --- a/core/dbt/ui/printer.py +++ b/core/dbt/ui/printer.py @@ -192,14 +192,16 @@ def print_model_result_line( result.execution_time) -def print_snapshot_result_line(result, index: int, total: int): +def print_snapshot_result_line( + result, description: str, index: int, total: int +) -> None: model = result.node info, status = get_printable_result(result, 'snapshotted', 'snapshotting') cfg = model.config.to_dict() - msg = "{info} {name}".format( - info=info, name=model.name, **cfg) + msg = "{info} {description}".format( + info=info, description=description, **cfg) print_fancy_output_line( msg, status,