diff --git a/sqlmesh/core/console.py b/sqlmesh/core/console.py index ca11b6e607..c9b38ea77d 100644 --- a/sqlmesh/core/console.py +++ b/sqlmesh/core/console.py @@ -4207,6 +4207,10 @@ def _format_node_error(ex: NodeExecutionFailedError) -> str: node_name = error.node.name elif hasattr(error.node, "snapshot_name"): node_name = error.node.snapshot_name + elif hasattr(error.node, "name"): + node_name = error.node.name + else: + node_name = str(error.node) msg = _format_node_error(error) msg = " " + msg.replace("\n", "\n ") @@ -4387,3 +4391,4 @@ def _calculate_annotation_str_len( + execution_stats_len, ) return annotation_str_len +