Method validate

dask/highlevelgraph.py:818–848

(self)

        return HighLevelGraph(ret_layers, ret_dependencies)

    def validate(self) -> None:
        # Check dependencies
        for layer_name, deps in self.dependencies.items():
            if layer_name not in self.layers:
                raise ValueError(f"dependencies[{layer_name!r}] not found in layers")
            for dep in deps:
                if dep not in self.dependencies:
                    raise ValueError(f"{dep!r} not found in dependencies")

        for layer in self.layers.values():
            assert hasattr(layer, "annotations")

        # Re-calculate all layer dependencies
        dependencies = compute_layer_dependencies(self.layers)

        # Check keys
        dep_key1 = self.dependencies.keys()
        dep_key2 = dependencies.keys()
        if dep_key1 != dep_key2:
            raise ValueError(
                f"incorrect dependencies keys {set(dep_key1)!r} "
                f"expected {set(dep_key2)!r}"
            )

        # Check values
        for k in dep_key1:
            if self.dependencies[k] != dependencies[k]:
                raise ValueError(
                    f"incorrect HLG dependencies[{k!r}]: {self.dependencies[k]!r} "
                    f"expected {dependencies[k]!r} from task dependencies"
                )

    def __repr__(self) -> str:
        representation = f"{type(self).__name__} with {len(self.layers)} layers.\n"