fix.

Author: tobiasraabe

src/_pytask/console.py

@@ -147,11 +147,7 @@ def format_node_name(
     """Format the name of a node."""
     if isinstance(node, PPathNode):
         if node.name != node.path.as_posix():
-            # Use getattr with default because on existing projects PNode.attribute does
-            # not exist. Remove with v0.6.0.
-            if data_catalog_name := getattr(node, "attributes", {}).get(
-                DATA_CATALOG_NAME_FIELD
-            ):
+            if data_catalog_name := node.attributes.get(DATA_CATALOG_NAME_FIELD):
                 return Text(f"{data_catalog_name}::{node.name}")
             return Text(node.name)
         name = shorten_path(node.path, paths)

src/_pytask/data_catalog.py

@@ -93,6 +93,11 @@ def __attrs_post_init__(self) -> None:
         # Initialize the data catalog with persisted nodes from previous runs.
         for path in self.path.glob("*-node.pkl"):
             node = pickle.loads(path.read_bytes())  # noqa: S301
+
+            # To ease transition from nodes with and without attributes and it if it
+            # does not exist. Necessary since #650. Remove in v0.6.0.
+            if not hasattr(node, "attributes"):
+                node.attributes = {DATA_CATALOG_NAME_FIELD: self.name}
             self._entries[node.name] = node
 
     def __getitem__(self, name: str) -> PNode | PProvisionalNode:

src/_pytask/data_catalog_utils.py

@@ -0,0 +1,6 @@
+"""Contains utilities for the data catalog."""
+
+__all__ = ["DATA_CATALOG_NAME_FIELD"]
+
+
+DATA_CATALOG_NAME_FIELD = "catalog_name"