Add data catalog name to nodes.

Author: tobiasraabe

Diff for: docs/source/how_to_guides/writing_custom_nodes.md

@@ -142,9 +142,9 @@ databases. [^kedro]
 
 ## References
 
-[^structural-subtyping]: Structural subtyping is similar to ABCs an approach in Python to enforce interfaces, but
-    it can be considered more pythonic since it is closer to duck typing. Hynek Schlawack
-    wrote a comprehensive
+[^structural-subtyping]: Structural subtyping is similar to ABCs an approach in Python to enforce interfaces,
+    but it can be considered more pythonic since it is closer to duck typing. Hynek
+    Schlawack wrote a comprehensive
     [guide on subclassing](https://hynek.me/articles/python-subclassing-redux/) that
     features protocols under "Type 2". Glyph wrote an introduction to protocols called
     [I want a new duck](https://glyph.twistedmatrix.com/2020/07/new-duck.html).

Diff for: pyproject.toml

@@ -84,12 +84,6 @@ Tracker = "https://github.com/pytask-dev/pytask/issues"
 [project.scripts]
 pytask = "pytask:cli"
 
-[tool.uv.sources]
-pytask-parallel = { workspace = true }
-
-[tool.uv.workspace]
-members = ["packages/*"]
-
 [tool.uv]
 dev-dependencies = [
     "tox-uv>=1.7.0", "pygraphviz"

Diff for: src/_pytask/console.py

@@ -24,6 +24,7 @@
 from rich.theme import Theme
 from rich.tree import Tree
 
+from _pytask.data_catalog_utils import DATA_CATALOG_NAME_FIELD
 from _pytask.node_protocols import PNode
 from _pytask.node_protocols import PPathNode
 from _pytask.node_protocols import PProvisionalNode
@@ -146,6 +147,12 @@ 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
+            ):
+                return Text(f"{data_catalog_name}::{node.name}")
             return Text(node.name)
         name = shorten_path(node.path, paths)
         return Text(name)

Diff for: src/_pytask/data_catalog.py

@@ -17,6 +17,7 @@
 from attrs import field
 
 from _pytask.config_utils import find_project_root_and_config
+from _pytask.data_catalog_utils import DATA_CATALOG_NAME_FIELD
 from _pytask.exceptions import NodeNotCollectedError
 from _pytask.models import NodeInfo
 from _pytask.node_protocols import PNode
@@ -133,3 +134,4 @@ def add(self, name: str, node: PNode | PProvisionalNode | Any = None) -> None:
                 msg = f"{node!r} cannot be parsed."
                 raise NodeNotCollectedError(msg)
             self._entries[name] = collected_node
+        self._entries[name].attributes[DATA_CATALOG_NAME_FIELD] = self.name

Diff for: src/_pytask/node_protocols.py

@@ -21,6 +21,7 @@ class PNode(Protocol):
     """Protocol for nodes."""
 
     name: str
+    attributes: dict[Any, Any]
 
     @property
     def signature(self) -> str:
@@ -116,6 +117,7 @@ class PProvisionalNode(Protocol):
     """
 
     name: str
+    attributes: dict[Any, Any]
 
     @property
     def signature(self) -> str:

Diff for: src/_pytask/nodes.py

@@ -167,6 +167,7 @@ class PathNode(PPathNode):
 
     path: Path
     name: str = ""
+    attributes: dict[Any, Any] = field(factory=dict)
 
     @property
     def signature(self) -> str:
@@ -237,6 +238,7 @@ class PythonNode(PNode):
     value: Any | NoDefault = no_default
     hash: bool | Callable[[Any], bool] = False
     node_info: NodeInfo | None = None
+    attributes: dict[Any, Any] = field(factory=dict)
 
     @property
     def signature(self) -> str:
@@ -306,6 +308,7 @@ class PickleNode(PPathNode):
 
     path: Path
     name: str = ""
+    attributes: dict[Any, Any] = field(factory=dict)
 
     @property
     def signature(self) -> str:
@@ -355,6 +358,7 @@ class DirectoryNode(PProvisionalNode):
     name: str = ""
     pattern: str = "*"
     root_dir: Path | None = None
+    attributes: dict[Any, Any] = field(factory=dict)
 
     @property
     def signature(self) -> str: