nodes.NodeStatus

Where one node stands; see Node.status. str() gives one line,

Usage

Source

nodes.NodeStatus(
    node, versions, stored=None, recomputed=None, touched=None, framed=False
)

such as “doubled: paid@v3; stored in lake/doubled”.

Parameter Attributes

node: str

The node’s name.

versions: dict[str, int] | None

The version of every source the node’s state reflects (as Node.versions), or None if it has not been refreshed in this process.

stored: str | None = None

The table the node is stored in (a Delta URI or an Iceberg identifier), or None if it is not stored.

recomputed: str | None = None

Why the node is recomputed on every refresh instead of maintained, or None if it is maintained from changes (or not refreshed yet).

touched: str | None = None

Why the node has no delta rules, when it is maintained by recomputing only the groups each batch touches (an aggregate, or a window’s partitions or frames).

framed: bool = False

The node recomputes window rows near the change, by their frames (touched frames).